java - 使用Completable的CompletableSource的不兼容类型

当我的上层可观察链流中发生错误时，我正在尝试处理错误（忽略它）。
我想使用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


如何正确处理呢？

最佳答案

您必须导入正确的类型：

import io.reactivex.Completable;

要么

return io.reactivex.Completable.complete();