У меня есть что-то вроде этого:
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();
}
});
В основном я хочу следующее:
- I need an observable to start, initially after 10seconds and then
- it does #1 when completed then
- это делает # 2, когда завершено, то
- он ждет 2 секунды и повторяет все, но первые 10 секунд ждут и должны работать вечно.
Я не могу найти способ, чтобы это работало. Он просто повторяет процесс каждые 2 секунды, не дожидаясь вызова onNext. Это должно быть так?