如何停止和恢复 Observable.interval 发出滴答声

Question

这将每 5 秒发出一次滴答声。

 Observable.interval(5, TimeUnit.SECONDS, Schedulers.io())
            .subscribe(tick -> Log.d(TAG, "tick = "+tick));

要停止它，您可以使用

Schedulers.shutdown();

但是随后所有的调度程序都停止了，以后不可能恢复滴答。我怎样才能“优雅地”停止和恢复发射？

原文由 Jan Seevers 发布，翻译遵循 CC BY-SA 4.0 许可协议

Answer 1

这是一种可能的解决方案：

 class TickHandler {

    private AtomicLong lastTick = new AtomicLong(0L);
    private Subscription subscription;

    void resume() {
        System.out.println("resumed");
        subscription = Observable.interval(5, TimeUnit.SECONDS, Schedulers.io())
                                 .map(tick -> lastTick.getAndIncrement())
                                 .subscribe(tick -> System.out.println("tick = " + tick));
    }

    void stop() {
        if (subscription != null && !subscription.isUnsubscribed()) {
            System.out.println("stopped");
            subscription.unsubscribe();
        }
    }
}

原文由 AndroidEx 发布，翻译遵循 CC BY-SA 3.0 许可协议

Answer 2

前段时间，我也在寻找一种 RX“定时器”解决方案，但没有一个符合我的期望。所以你可以找到我自己的解决方案：

 AtomicLong elapsedTime = new AtomicLong();
AtomicBoolean resumed = new AtomicBoolean();
AtomicBoolean stopped = new AtomicBoolean();

public Flowable<Long> startTimer() { //Create and starts timper
    resumed.set(true);
    stopped.set(false);
    return Flowable.interval(1, TimeUnit.SECONDS)
            .takeWhile(tick -> !stopped.get())
            .filter(tick -> resumed.get())
            .map(tick -> elapsedTime.addAndGet(1000));
}

public void pauseTimer() {
    resumed.set(false);
}

public void resumeTimer() {
    resumed.set(true);
}

public void stopTimer() {
    stopped.set(true);
}

public void addToTimer(int seconds) {
    elapsedTime.addAndGet(seconds * 1000);
}

原文由 Artur Szymański 发布，翻译遵循 CC BY-SA 3.0 许可协议