kotlin - RxJava:忽略Flowable中的一些错误

Question

我有一个Flowable<T>和我想忽略的IgnoreThisError子类型的错误(导致正常完成)，所有其他错误应向下游传播。

Kotlin示例:

val f : Flowable<T> = ...
val g = f.onErrorComplete { it is IgnoreThisError }

此功能onErrorComplete是我需要的，不存在...

Answer 1

这样的事情应该工作

f.onErrorResumeNext {
    if (it is IgnoreThisError)
        Flowable.empty()
    else
        Flowable.error(it)
}

我不确定Kotlin是否会由于重载和Java对签名方差的模拟而在此处正确推断类型，如果不是这样，则可能需要更明确地说明:

f.onErrorResumeNext(Function<Throwable, Publisher<T>> {
    if (it is IgnoreThisError)
        Flowable.empty()
    else
        Flowable.error(it)
})