Я пытаюсь обработать ошибку (игнорировать ее), когда она возникает в моем верхнем наблюдаемом цепном потоке.
Я хочу использовать для этого функцию onErrorResumeNext
.
Однако, когда я использую это так
.... //some actions
.onErrorResumeNext(new Function<Throwable, CompletableSource>() {
@Override
public CompletableSource apply(Throwable throwable) throws Exception {
return Completable.complete();
}
})
IDE подчеркивает строку return Completable.complete()
с ошибкой:
Incompatible types. Required: io.reactivex.CompletableSource Found: rx.Completable
Как с этим справиться?
Вам необходимо импортировать правильный тип:
import io.reactivex.Completable;
или же
return io.reactivex.Completable.complete();