rx-java - 链 Completable 到 Observable 流

Question

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

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

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

还有什么？

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