RxJava: как разделить Single

Question

Как разделить отдельный поток на отдельные отдельные потоки, чтобы я мог выполнить следующее, не вычисляя getUserId() дважды?

// getUserId() returns Single<String>

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

Answer 1

Кэшируйте результат getUserId, используя cache

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