RxJava / RxKotlin：等待异步获取值，然后提供给所有订阅者

问题描述

我有一种情况，我必须异步获取一些字符串。我想创建一个方法，在此方法中，当成功获取此值然后提供给侦听器时，我可以进行侦听。 现在，可以通过多种方法轻松完成此操作，包括回调侦听器或lambda。

但是我该使用什么，以便所有对该方法的后续调用也都提供了该字符串-无需再次获取它，因为它已经被获取了一次。因此，一种解决方案，其中侦听器仍处于连接状态，但由于可用而立即获得了值。 我知道如何通过老式的回调侦听器来执行此操作，在其中存储值，然后对于后续调用，可以立即通过回调将其返回。

但是有没有更紧凑/更复杂的方法，比如说通过Rx？

谢谢。

解决方法

我认为您可以只使用cache()运算符。会是这样的：

val value: Single<String> by lazy {
    // emulation of your callback
    Single.create<String> { emitter ->
        Thread.sleep(1000)
        println("do some work")
        emitter.onSuccess("test")
    }.cache()
}

fun main() {
    value.subscribe { str -> println(str) }
    value.subscribe { str -> println(str) }
    value.subscribe { str -> println(str) }
    Thread.sleep(2000)
    // output:
    // do some work
    // test
    // test
    // test
}