scala - scala.rx タイマーに制限を設定する

Question

以下は、scala.rx の Timer を使用した例です。

package tutorial.webapp

import akka.actor.ActorSystem
import rx.core.{Rx, Var}
import rx._
import rx.ops._

import scala.concurrent.Promise
import scala.concurrent.duration._
import scala.scalajs.js.JSApp
import scala.scalajs.js.annotation.JSExport
import scala.concurrent.ExecutionContext.Implicits.global

/**
 * Created by IDEA on 29/10/15.
 */
object RxAddtionalOps extends JSApp {
  @JSExport
  override def main(): Unit = {
    timer1
  }

  def timer1: Unit = {
    implicit val scheduler = new DomScheduler        
    val t = Timer(100 millis)
    var count = 0
    val o = Obs(t){
      count = count + 1
      println(count)
    }
  }
}

sbt から実行するrunMain tutorial.webapp.RxAddtionalOpsと、コンソールは無期限にブロックされます。タイマーに制限を設定できますか? たとえば、イベントの発行を 2 分で停止するには、次のようにします。