RxJava-每秒发出一个可观察到的

Question

我正在用RxJava在Android中制作计时器。我需要在RxJava中制作一个计时器，以便每秒发出一个可观察的信号。我试过以下方法，但没有成功。有没有想过我做错了什么？

Observable.interval(1000L, TimeUnit.MILLISECONDS)
          .timeInterval()
          .observeOn(AndroidSchedulers.mainThread())
          .subscribe({Log.d(LOG_TAG, "&&&& on timer") })

Answer 1

静态编程语言

val list = IntRange(0, 9).toList()
val disposable = Observable
    .interval(0,1, TimeUnit.SECONDS)
    .map { i -> list[i.toInt()] }
    .take(list.size.toLong())
    .subscribe {
       println("item: $it")
    }
Thread.sleep(11000)

Answer 2

在您的订阅（）中，您不会使用timeInterval（）运算符返回的long TimeInterval对象。

正确版本：

.subscribe(longTimeInterval -> {
     Log.d(LOG_TAG, "&&&& on timer"); 
}

此外，我认为您根本不需要timeInterval（）操作符<代码>可观察。interval（）将在您的情况下每秒发出一个可观察到的，我猜这就是您想要的timeInterval（）将其转换为一个可观测值，该值保存两个事件发生之间的确切时间差，我怀疑您是否需要它。

Answer 3

您的代码似乎没有被调用。检查是否执行以及何时执行。在使用可观察的时，它是完全正确的。

例如，我将您的片段放在我的Mainactive的onCreate（...）中：

override fun onCreate(savedInstanceState: Bundle?) {
    super.onCreate(savedInstanceState)
    Observable.interval(1000L, TimeUnit.MILLISECONDS)
            .timeInterval()
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe { Log.d("tag", "&&&& on timer") }
    // ...
}

它的工作原理：

而且，您可能不需要。timeInterval（）因为可以观察到。间隔（…） 本身在指定的速率内发出序列号，并且<代码>。timeInterval（）只是将其转换为发射两次发射之间经过的时间间隔。