rxjava interval（）某个事件后的重置时间

Question

我正在用RxJava做一个Android应用程序，在其中一个页面上，我有一个按钮，当按下时，页面会做一个刷新。而且我还希望每10秒自动刷新一次，如果用户在此期间没有按下按钮。但是当用户点击按钮时，我希望自动刷新动作发生在点击后10秒钟。而不是继续自己的10秒间隔。例如，在第0秒，应用程序做一个自动刷新，然后在第3秒，用户按下按钮。然后自动刷新应该发生在第13秒，第23秒，等等。我知道有一个interval()运算符以一定的间隔发出项。但似乎没有办法“重置”开始时间。它有点像取消订阅和订阅interval()可以再次观察到。一段代码就像

Observable<Long> intervalObservable = Observable.inteval(10, TimeUnit.SECONDS)
RxView.click(refreshButton).map(ignored -> 0L)
      .merge(intervalObservable)
      .subscibe(ignore -> performRefresh());

如果有一种方法可以“取消合并”intervalobservable，那么我可以在下一个中取消合并，然后再次合并。但似乎没有。我怎样才能做到这一点？

Answer 1

使用switchmap运算符可以很好地完成这一任务。每次按下按钮时，它将切换到可观察间隔的新订阅--这意味着它将重新开始。上一个订阅将自动删除，因此不会有多个间隔运行。

Observable<Long> intervalObservable = Observable.interval(10, TimeUnit.SECONDS);

RxView.clicks(refreshButton)
    .switchMap(ignored -> {
        return intervalObservable
            .startWith(0L)                 // For an immediate refresh
            .observeOn(AndroidSchedulers.mainThread())
            .doOnNext(x -> performRefresh());
    })      
    .subscribe();

StartWith向间隔添加一个即时值（单击按钮时立即导致刷新），而ObserveOn确保刷新发生在主线程上（这很重要，因为间隔将在后台线程上发出）。

更新：vman注意到，这个实现只有在用户第一次单击按钮后才开始刷新。下面的替代方案将在订阅时立即刷新，然后每10秒刷新一次，直到单击按钮--此时它将再次立即刷新，然后每10秒继续更新一次。

Observable<Long> intervalObservable = Observable.interval(10, TimeUnit.SECONDS)
    .startWith(0L)  // For an immediate refresh
    .observeOn(AndroidSchedulers.mainThread())
    .doOnNext(x -> performRefresh());

Observable<Long> buttonClickedObservable = RxView.clicks(refreshButton)
    .map(e -> 0L)  // To make the compiler happy
    .switchMap(ignored -> Observable.error(new RuntimeException("button pressed")));

Observable.merge(intervalObservable, buttonClickedObservable)
    .retry()
    .subscribe();