RxJava订阅许多可观察到的对象并不为所有订阅者触发onNext（）？

Question

当我创建5个observables并用单独的订阅者订阅它们时，直觉上我认为每个订阅者都将获得其observables的相应数据，这些数据通过onNext（）调用发出：

val compositeSubscription = CompositeDisposable()

fun test() {

        for (i in 0..5) {
            compositeSubscription.add (Observable.create<String>(object : ObservableOnSubscribe<String> {
                override fun subscribe(emitter: ObservableEmitter<String>) {
                    emitter.onNext("somestring")
                    emitter.onComplete()
                }
            }).subscribeOn(Schedulers.computation())
                .observeOn(AndroidSchedulers.mainThread())
                    .subscribe({
                        Logger.i("testIt onNext")
                    }, {
                        Logger.i("testIt onError")
                    }))
        }
}

然而，我在日志中看到的是一两个“testit onnext”。

如果有任何提示，我将不胜感激。

Answer 1

从这个代码来看，每个订阅者都应该打印“Testt onNext”。你确定它没有被打印出来吗？也许Android Studio正在崩溃相同的线路？您是否尝试为每个订阅者打印不同的内容？