假设您要在Observable链中插入Completable，例如对于每个发出的元素，都有一个complet会运行并阻塞直到完成，您会选择哪个选项？ （此处Completable.complete()仅作为示例）.flatMap { Completable.complete().andThen(Observable.just(it)) }.doOnNext { Completable.complete().blockingAwait() }
还有什么吗
最佳答案
.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