rxjava为什么没有执行onNext方法

Question

我写了一个打印 flatMap 输出的方法（伪代码）：

Observable.just(...).repeat()
    .flatMap( return Observable.just([double]))
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(new Subscriber<Double>() {
        @Override
        public void onCompleted() {

        }

        @Override
        public void onError(Throwable e) {
            tvConfidence.setText(e.getMessage());
        }

        @Override
        public void onNext(Double aDouble) {
            tvConfidence.setText("Confidence :" + aDouble);
        }
    });

当我运行这些代码时，它会运行几秒钟，但几秒钟后，它不会再次运行到 onNext 方法上。不知道为什么，因为我调试代码，它会运行Observable.just(double)，并且值总是改变但它不会执行代码setText刷新textView。

Answer 1

我的猜测是，由于特定的flatMap 过载，您最终会开始积累大量just，因为flatMap 是无限的。尝试使用flatMap(f, 1) 来限制并发级别。