在 RxJava 中调用 onNext 之间暂停 [英] Pause between call onNext in RxJava

问题描述

如何在 onNext 方法调用之间延迟?我有一个代码:

How to make delay between onNext method calling? I have a code:

Observable<Integer> obs = Observable.range(1, 1000)
                    .subscribeOn(Schedulers.io())
                    .observeOn(AndroidSchedulers.mainThread());
            subs = obs.subscribe(new Subscriber<Integer>() {
                @Override
                public void onNext(Integer number) {
                    mCurrentNumber = number;
                    mCounter.setText(String.valueOf(number));
                }

                @Override
                public void onCompleted() {
                    isRunning = false;
                }

                @Override
                public void onError(Throwable e) {

                }
            });

例如，我需要设置一个 100 毫秒的暂停

For example, I need to set a pause for 100 milliseconds

推荐答案

好吧，你可以使用 interval 运算符，它将在指定的时间间隔后发出项目，并使用 take 运算符仅使用所需数量的流项目

Well you can use interval operator which will emit items after a specified interval of time and use take operator to use only required numbers of stream items

Observable.interval(100, TimeUnit.MILLISECONDS)
        .take(1000)
         .subscribe(new Action1<Long>() {
          @Override public void call(Long timerValue) {

        }
        });

这篇关于在 RxJava 中调用 onNext 之间暂停的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！