跳转至

了解 RxJava 定时器、延迟和间隔运算符

原文:https://www . geesforgeks . org/understanding-rxjava-timer-delay-and-interval-operators/

在这篇文章中，我们将学习 RxJava 定时器、延迟和间隔操作符。此外，所有不同的计时器、延迟和间隔操作符的用例将在本文中得到澄清，所以请一直关注到最后。通过例子，我们将研究以下所有操作。

  • Timer
  • Delay
  • interval

让我们从 RxJava 计时器操作符开始。当我们想要在一定时间后做某事时，使用 Timer 运算符。

计时器操作员示例

我的锅

Observable.timer(5, TimeUnit.SECONDS)
    .flatMap {
        return@flatMap Observable.create<String> { shooter ->
            Log.d("gfgArticleExampe", "Shoot")
            shooter.onNext("GeeksforGeeks")
            shooter.onComplete()
            // Action to be done when completed 10 secs
        }
    }
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe {
        Log.d("gfgArticleExampe", it)
}

上面的例子向我们展示了我们所说的计时器操作符。当我们进入计时器操作器 10 秒钟后，它会以这种方式移动到另一个任务，我们在 10 秒钟内完成任务，并发出值“geeks forgeeks。”

极客提示#1: 当我们有一个用例，我们希望在一定时间后完成一项工作，我们可以使用计时器操作符。

现在，我们来看看 RxJava 延迟算子。延迟操作器将排放量从可观测值提前一个指定的量。让我们看一个延迟运算符的例子。

延迟运算符示例

我的锅

Observable.create<String> { emitter ->
    Log.d("DelayGFG", "Shoot")
    emitter.onNext("GeeksforGeeks")
    emitter.onComplete()
}
.subscribeOn(Schedulers.io())
.delay(10, TimeUnit.SECONDS)
.observeOn(AndroidSchedulers.mainThread())
.subscribe {
    Log.d("DelayGFG", it)
}

我们正在做一些工作，然后发出一个值，但是我们想推迟向订户发出值，所以我们使用了延迟运算符。

极客提示#2: 当我们有一个用例，我们希望先执行工作，然后将排放推迟一段特定的时间，我们可以使用延迟运算符。

让我们看一下 RxJava 区间运算符，它生成一个可观测值，该值发出由时间间隔分隔的整数序列。

区间运算符示例

我的锅

val disposable =
    Observable.interval(1, 10, TimeUnit.SECONDS)
        .flatMap {
            return@flatMap Observable.create<String> { shooter ->
                Log.d("GfGInterval", "Shoot")
                shooter.onNext("GeeksforGeeks")
                shooter.onComplete()
            }
        }
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe {
            Log.d("GfGInterval", it)
        }
compositeDisposable.add(disposable)

在这种情况下，任务将在 10 秒钟的延迟后重复。有一点要记住:会无限期持续下去。

那么如何摆脱这个循环呢？

嗯，有两种方法可以停止:

  • Using compound configurability.
  • dispose () can be called by the take(n) operator.

结论

当我们有一个用例，我们希望以某个时间间隔重复一个作业时，我们可以使用间隔运算符。另一件要记住的事情是，所有的计时器、延迟和间隔操作符都在调度器线程上运行，因此我们不必担心它。为了解决这个有趣的问题，我们可以使用 RxJava 计时器、延迟和间隔运算符。

回到顶部