RxJava Timer Observable 但等待完成

Question

我有这样的东西：

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();
                    }
                });

基本上我想要的是：

我需要一个 observable 来启动，最初是在 10 秒之后，然后
- 它在完成后执行#1
- 完成后执行#2
- 它等待 2 秒并重复所有事情，但前 10 秒等待并且应该运行永远。

我找不到让它工作的方法。它只是每 2 秒重复一次该过程，而无需等待 onNext 被调用。应该是这样吗？

Answer 1

怎么样

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

RxJava Timer Observable 但等待完成

RxJava Timer Observable but wait to complete

rx-java