我正在学习monix 3
。
下一个代码:
object Main extends TaskApp {
override def runc = {
Observable.fromIterable(1 to 10)
.map{i =>
val delay = Random.nextInt(1000) + 1000
println(s"Starting $i, delay = $delay")
Thread.sleep(delay) // Imitation of hard execution
i
}
.map{i =>
val delay = Random.nextInt(1000) + 1000
println(s"Continue $i, delay = $delay")
Thread.sleep(delay)
i
}
.consumeWith(Consumer.loadBalance(3, Consumer.foreach(i => println(s"End $i")))) //Compile error here
}
}
导致编译错误:
缺少参数类型
.consumeWith(Consumer.loadBalance(3, Consumer.foreach(i => println(s"End $i"))))
我想不通,这里出了什么问题,以及如何使这段代码编译?
UPD
第二个问题是如何每n
分钟重复一次这个流?