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

Я пытаюсь обработать ошибку (игнорировать ее), когда она возникает в моем верхнем наблюдаемом цепном потоке. Я хочу использовать для этого функцию 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

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

Пользовательский скаляр GraphQL
Пользовательский скаляр GraphQL
Листовые узлы системы типов GraphQL называются скалярами. Достигнув скалярного типа, невозможно спуститься дальше по иерархии типов. Скалярный тип...
Как вычислять биты и понимать побитовые операторы в Java - объяснение с примерами
Как вычислять биты и понимать побитовые операторы в Java - объяснение с примерами
В компьютерном программировании биты играют важнейшую роль в представлении и манипулировании данными на двоичном уровне. Побитовые операции...
Поднятие тревоги для долго выполняющихся методов в Spring Boot
Поднятие тревоги для долго выполняющихся методов в Spring Boot
Приходилось ли вам сталкиваться с требованиями, в которых вас могли попросить поднять тревогу или выдать ошибку, когда метод Java занимает больше...
Полный курс Java для разработчиков веб-сайтов и приложений
Полный курс Java для разработчиков веб-сайтов и приложений
Получите сертификат Java Web и Application Developer, используя наш курс.
1
0
373
1
Перейти к ответу Данный вопрос помечен как решенный

Ответы 1

Ответ принят как подходящий

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

import io.reactivex.Completable;

или же

return io.reactivex.Completable.complete();

Другие вопросы по теме