【发布时间】:2015-10-28 14:48:10
【问题描述】:
我有这样的事情:
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 被调用。应该是这样吗?
【问题讨论】:
-
很难理解你在追求什么。你想:暂停 10 秒,运行 1,运行 2,等待 2 秒,重复吗?
-
是的。重复除第一个暂停以外的所有内容
标签: rx-java