RxJava定时器可观察,但等待完成



我有这样的东西:

return Observable.timer(2, TimeUnit.SECONDS)
                .flatMap(integer -> captureList.getLatestCaptureCut()) #1
                .flatMap(vp::processVideo) #2
                .observeOn(AndroidSchedulers.mainThread())     
                .repeat()
                .subscribeOn(Schedulers.computation())
                .subscribe(new Subscriber<Boolean>() {
                    @Override
                    public void onCompleted() {
                    }
                    @Override
                    public void onNext(Boolean aBoolean) {
                    }
                    @Override
                    public void onError(Throwable e) {
                        e.printStackTrace();
                    }
                });

基本上我想要的是:

  • 我需要一个可观察对象开始,最初在10秒后,然后
    • 完成后执行#1,然后
    • 完成后执行#2然后
    • 它等待2秒,重复一切,但前10秒等待,应该永远运行。

我找不到这个工作的方法。它只是每2秒重复这个过程,而不等待onNext被调用。应该是这样吗?

Observable.timer(10, 2, TimeUnit.SECONDS)

相关内容

  • 没有找到相关文章

最新更新