【问题标题】:RxJava: Merge an observable with a completable based on the result of the first emission of the observableRxJava:根据可观察对象的第一次发射结果将可观察对象与可完成对象合并
【发布时间】:2019-02-12 00:30:16
【问题描述】:

我有一个持续发射的 observable,但我需要在基于 observable 的第一次发射的条件下运行一个 Completable。即使可完成对象完成,可观察对象仍将继续发射。我试图四处寻找执行此操作的操作员,但找不到。我怎么可能做到这一点?

【问题讨论】:

    标签: android rx-java2


    【解决方案1】:

    类似的东西-

    observable
      .flatMap(value -> {
         return (value == something ? completableThatDoesSomething : Completable.complete())
           .andThen(Observable.just(value));
      })
    
    

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2019-04-23
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2020-02-11
      • 1970-01-01
      相关资源
      最近更新 更多