【问题标题】:RxJava Timer Observable but wait to completeRxJava Timer Observable 但等待完成
【发布时间】: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


【解决方案1】:

怎么样

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

【讨论】:

    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2018-06-29
    • 2018-10-06
    • 2018-08-06
    • 1970-01-01
    • 2017-09-20
    相关资源
    最近更新 更多