【发布时间】:2019-02-12 00:30:16
【问题描述】:
我有一个持续发射的 observable,但我需要在基于 observable 的第一次发射的条件下运行一个 Completable。即使可完成对象完成,可观察对象仍将继续发射。我试图四处寻找执行此操作的操作员,但找不到。我怎么可能做到这一点?
【问题讨论】:
我有一个持续发射的 observable,但我需要在基于 observable 的第一次发射的条件下运行一个 Completable。即使可完成对象完成,可观察对象仍将继续发射。我试图四处寻找执行此操作的操作员,但找不到。我怎么可能做到这一点?
【问题讨论】:
类似的东西-
observable
.flatMap(value -> {
return (value == something ? completableThatDoesSomething : Completable.complete())
.andThen(Observable.just(value));
})
【讨论】: