假设您想在Observable链中插入一个Completable,例如对于每个发出的元素,都有一个Completable运行并阻塞直到其完成,您会选择哪个选项?(这里的Completable.complete()
只是为了举例)
.flatMap { Completable.complete().andThen(Observable.just(it)) }
.doOnNext { Completable.complete().blockingAwait() }
其他方法?
假设您想在Observable链中插入一个Completable,例如对于每个发出的元素,都有一个Completable运行并阻塞直到其完成,您会选择哪个选项?(这里的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
blockingAwait()
不受可观察流程管理,您将失去取消完成的能力。flatMapCompletable
。