rx-java - 如何将 OnComplete 和 OnError 事件作为可观察项发出？

Question

我想从发出 Completable 的 OnError 和 OnComplete 事件的 Completable 创建 Observable。

事件示例:

    private sealed class Result {

        class Success : Result()

        class Error(val errorMessage: String) : Result()
    }

OnError 事件应映射到 Error，OnComplete 应映射到 Success

我理解如果 observable 发出错误事件时如何发出 Error:

val completable = ...
completable.
    .toObservable<Result>()
    .onErrorReturn { error -> Result.Error(error.message.orEmpty()) }

但我找不到发出 OnComplete 事件的解决方案。是否可以使用标准的 RxJava 运算符？

Answer 1

利用.materialize()功能。

例如像这样:

Completable.complete()
        .toObservable<Result>()
        .materialize()
        .map {
            when {
                it.isOnError -> 1
                it.isOnComplete -> 0 
                else -> 2 // not present in Completable
            }
        }