rx-java – 链可完成到Observable流

发布时间：2020-12-15 03:02:28 所属栏目：Java 来源：网络整理

导读：假设您要在Observable链中插入Completable,例如对于每个发出的元素,有一个可运行的块并在其完成之前阻塞,您会选择哪个选项？ (这里的Completable.complete()就是一个例子) .flatMap {Completable.complete().andThen(Observable.just(it))} .doOnNext {Compl

假设您要在Observable链中插入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

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!