observable - RxKotlin，RxJava：Observable/Single 未启动

Question

我有以下类，它公开一个 Single 来获取 ID。

这用于在该类的 init 上获取 ID，以后其他人也可以使用它来获取 ID。

从我订阅此单曲的任何其他地方，我都能获得 ID。但是这里的init方法中，这个方法似乎并没有启动并获取ID。

有人可以帮我理解我所缺少的吗？谢谢

class TestClass {

val idObservable: Single<String>
    get() {
        return Single.create {
            fetchId(it)
        }
    }

init {
    idObservable
        .subscribe { success, _ ->
            Log.d(TAG, "Id: $success")
        }
        .dispose()
}

private fun fetchId(emitter: SingleEmitter<String>) {
    Utils.fetchId(Consumer<String>{
        emitter.onSuccess(it)

    }, Consumer<Throwable>{
        emitter.onSuccess("")
    })
}

}

标签： observablerx-javarx-java2publish-subscriberx-kotlin2

Answer 1

它在构造函数 init 中不起作用的原因是单曲被立即处理掉了。

init {
idObservable
    .subscribe { success, _ ->
        Log.d(TAG, "Id: $success")
    }

}

上面的代码有效。