我有这样的东西:
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)