Тип выражения аргумента Scala RxJava несовместим с типом формального параметра - PullRequest
Новая
       25

Тип выражения аргумента Scala RxJava несовместим с типом формального параметра

0 голосов
/ 08 октября 2018

Я пытался реализовать простую обработку веб-сокетов, используя набор инструментов Vertx, используя библиотеку RxJava и язык Scala.

И я получаю сообщение об ошибке при передаче анонимного класса в метод RxJava map 

websocket
    .flatMap(socket => socket.toObservable)
    .map(new Function[Buffer, String] {
      override def apply(msg: Buffer): String = {
        msg.toString
      }
    })

Трассировка стека компилятора: 

Error:(61, 6) no type parameters for method map: (x$1: io.reactivex.functions.Function[_ >: io.vertx.reactivex.core.buffer.Buffer, _ <: R])io.reactivex.Observable[R] exist so that it can be applied to arguments (io.reactivex.functions.Function[io.vertx.reactivex.core.buffer.Buffer,String])
 --- because ---
argument expression's type is not compatible with formal parameter type;
 found   : io.reactivex.functions.Function[io.vertx.reactivex.core.buffer.Buffer,String]
 required: io.reactivex.functions.Function[_ >: io.vertx.reactivex.core.buffer.Buffer, _ <: ?R]
Note: io.vertx.reactivex.core.buffer.Buffer <: Any, but Java-defined trait Function is invariant in type T.
You may wish to investigate a wildcard type such as `_ <: Any`. (SLS 3.2.10)
    .map(new Function[Buffer, String] {


Error:(61, 10) type mismatch;
 found   : io.reactivex.functions.Function[io.vertx.reactivex.core.buffer.Buffer,String]
 required: io.reactivex.functions.Function[_ >: io.vertx.reactivex.core.buffer.Buffer, _ <: R]
    .map(new Function[Buffer, String] {

сигнатура метода карты в RxJava: 

@CheckReturnValue
    @SchedulerSupport(SchedulerSupport.NONE)
    public final <R> Observable<R> map(Function<? super T, ? extends R> mapper) {
        ObjectHelper.requireNonNull(mapper, "mapper is null");
        return RxJavaPlugins.onAssembly(new ObservableMap<T, R>(this, mapper));
    }

В трассировке стека компилятора я вижу, что функция получает нижнюю границу Buffer, и она должна работать, но не работает't.

Как исправить проблему времени компиляции, передавая правую лямбду в map функцию?

1 Ответ

0 голосов
/ 09 октября 2018

Попробуйте указать тип параметра: 

websocket
  .flatMap(socket => socket.toObservable)
  .map[String]((msg: Buffer) => {
    msg.toString
  })

или 

websocket
  .flatMap(socket => socket.toObservable)
  .map[String](new Function[Buffer, String] {
    override def apply(msg: Buffer): String = {
      msg.toString
    }
  })
...