代码之家 › 专栏 › 技术社区 › Jack Guo

rxjava:如何拆分单个

rx-java kotlin

Jack Guo · 技术社区 · 7 年前

如何将单个流拆分为单独的单个流,以便我可以在不进行计算的情况下执行以下操作 getUserId() 两次?

// getUserId() returns Single<String>

getUserId().flatMap { getSomething(it) }  // Return Single<Something>
getUserId().flatMap { getSomethingElse(it) } // Return Single<SomethingElse>

1 回复 | 直到 7 年前

Sourabh 7 年前

缓存的结果 getUserId 使用 cache

val userIdCached = getUserId().cache()
userIdCached
    .flatMap { getSomething(it) }
    .subscribe(...)
userIdCached
    .flatMap { getSomethingElse(it) }
    .subscribe(...)

推荐文章

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 年前