保留可观察到的错误和 return 所有值

Question

你好，我有这样的东西：

Observable.fromIterable(0..4)
        .map { if (it == 3) throw Exception() else it }
        .subscribe { println(it) }

我希望它 return 除了一个以外的所有值（它 == 3 必须由于错误而被跳过）。怎么做到的？

Answer 1

它可以通过 Maybe:

中的包装来完成

Observable.fromIterable(0..4)
    .flatMapMaybe {
        Maybe.fromCallable { if (it == 3) throw Exception() else it }
            .onErrorComplete()
    }
    .subscribe { println(it) }