链 Completable 成 Observable 流

Question

假设你想在你的 Observable 链中插入一个 Completable，比如对于每个发射的元素，都有一个 Completable 运行并阻塞直到它完成，你会选择什么选项？ （这里Completable.complete()只是举例）

1. .flatMap { Completable.complete().andThen(Observable.just(it)) }

2. .doOnNext { Completable.complete().blockingAwait() }

3. 还有别的吗？

Answer 1

.flatMapCompletable { Completable.complete().andThen(Observable.just(it)) } // If you don't want it to return
.flatMap { Completable.complete().andThen(Observable.just(it)) } //Can be used if you want it to return Observable

Answer 2

在选项 2 中，您将失去取消可完成的功能，因为 blockingAwait() 不受可观察流管理。

如果不需要返回发射的元素，还有flatMapCompletable。

如果您需要执行可完成但还返回发出的元素，那么我会选择选项 1。