Несовместимые типы для CompletableSource с использованием Completable

Question

Я пытаюсь обработать ошибку (игнорировать ее), когда она возникает в моем верхнем наблюдаемом цепочечном потоке. Я хочу использовать функцию onErrorResumeNext для этого. Однако, когда я использую его, как это

.... //some actions
.onErrorResumeNext(new Function<Throwable, CompletableSource>() {
        @Override
        public CompletableSource apply(Throwable throwable) throws Exception {
         return Completable.complete();
        }
      })

IDE подчеркивает строку return Completable.complete() с ошибкой:

Несовместимые типы. Необходимые: io.reactivex.CompletableSource Найденный: rx.Completable

Как правильно с этим справиться?

Answer 1

Вы должны импортировать правильный тип:

import io.reactivex.Completable;

или

return io.reactivex.Completable.complete();