为什么 awakeEvery 已从 scalaz-stream 中删除答案

【问题标题】：Why awakeEvery was removed from scalaz-stream为什么 awakeEvery 已从 scalaz-stream 中删除
【发布时间】：2015-09-29 19:13:42
【问题描述】：

我发现在现代 scalaz-stream 中 scalaz.stream.Process 内没有更多的 awakeEvery。那么如何运行带句号的东西呢？

【问题讨论】：

标签： scala scalaz scalaz7 scalaz-stream

【解决方案1】：

已移至scalaz.stream.time 包：

import scalaz.stream._

scala> implicit val sc = new java.util.concurrent.ScheduledThreadPoolExecutor(1) 
sc: java.util.concurrent.ScheduledThreadPoolExecutor = java.util.concurrent.ScheduledThreadPoolExecutor@6b9013a5[Running, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0]

scala> import time._
import time._

scala> awakeEvery(1 second)
res22: scalaz.stream.Process[scalaz.concurrent.Task,scala.concurrent.duration.Duration] = Await(scalaz.concurrent.Task@798e0ec5,<function1>)

用法：

import scalaz.stream.io._

scala> awakeEvery(1 second).map(_.toString).take(10).to(stdOutLines).run.run
1071184213 nanoseconds
2070400738 nanoseconds
3069559214 nanoseconds
4066587711 nanoseconds
5071218561 nanoseconds
6071221562 nanoseconds
7071216340 nanoseconds
8067705406 nanoseconds
9066798501 nanoseconds
10066190672 nanoseconds

【讨论】：