代码之家 › 专栏 › 技术社区 › Chad Schultz

如何在RxJava流的中间有条件地添加异步操作?

rx-kotlin rx-android rx-java kotlin android

Chad Schultz · 技术社区 · 7 年前

makeServerCall()
                .doOnNext {
                    doStuff(it)
                }
                //TODO: if it == 0, call asyncOperation() and wait for its callback to fire 
                //before running the rest of the stream. Otherwise immediately run the rest
                //of the stream
                .flatMap {
                    observable1(it)
                    observable2(it)
                    Observable.merge(
                            getSpotSearchObservable(observable1),
                            getSpotSearchObservable(observable2)
                }
                .subscribeBy(onNext = {
                allDone()
                    view?
                })

我该怎么挤电话给 asyncOperation()

1 回复 | 直到 7 年前

akarnokd 7 年前

平面地图!

.flatMap {
    if (it == 0) {
        return@flatMap asyncOperation()
            .ignoreElements()
            .andThen(Observable.just(0))
    }
    return@flatMap Observable.just(it)
}
.flatMap {
    observable1(it)
    observable2(it)
    Observable.merge(
        getSpotSearchObservable(observable1),
        getSpotSearchObservable(observable2)
    )
}

推荐文章

Victor Dmitrienko · RxJava解Bounce运算符取决于消息

7 年前

Myk Willis · 将具有指定泛型列表类型的Observable作为方法参数传递

7 年前

Mangat Rai Modi · 垂直。x反应式卡夫卡客户端:编写时链接不起作用?

7 年前

n0shadow · RxJava:为一个完整表列表指定最大并发性

7 年前

Jhon Fredy Trujillo Ortega · 如何在平面图中使用等待方法?

7 年前

casolorz · 可合成。清除导致OkHttp抛出java。lang.IllegalStateException:输入/退出不平衡

7 年前

O10 · 与observeOn组合时,RxJava启动时忽略运算符

7 年前

ddinchev · RxJava2并行执行一组completable并等待全部完成

7 年前

advice · RxJava-捕获使用者异常

7 年前

Daksh · 条件链单链和完全链

7 年前