RxJava Таймер Наблюдаемые но ждать, чтобы завершить

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

В основном то, что я хочу следующее:

• мне нужно наблюдаемым начать, сначала после 10 секунд, а затем
  • он делает # 1 по завершении затем
  • он делает # 2 по завершении затем
  • подождите 2 секунды и повторите все, но первые 10 ждут и должны бежать вечно.

Я не могу найти способ, чтобы это работало. Он просто повторяет процесс каждые 2 секунды, не дожидаясь, когда onNext будет вызван. Должно быть, это так?

Answer 1

Как насчет

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