Rxjava почему не выполнил метод onNext

Я написал метод для печати вывода из 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.