multithreading - RxScala : How to keep the thread doing Observable.间隔还活着吗？

Question

我正在尝试编写一个简单的RxScala程序:

import rx.lang.scala.Observable

import scala.concurrent.duration.DurationInt
import scala.language.{implicitConversions, postfixOps}

object Main {
  def main(args: Array[String]): Unit = {
    val o = Observable.interval(1 second)
    o.subscribe(println(_))
  }
}

当我运行该程序时，我看不到任何打印输出。我怀疑这是因为在 Observable.interval中产生数字的线程死亡。我注意到在 RxScalaDemo中有一个对 waitFor(o)的调用，但是我不知道从哪里导入了它。

如何使该程序始终运行以打印数字序列？

Answer 1

您看不到任何内容，因为订阅main后，Observable方法立即退出。到此，您的程序就完成了。

像这样的测试程序的一个常见技巧是订阅后从stdin读取一个字节。