6

我正在尝试编写以下函数

def haltOnUserInput[O](process: Process[Task, O]): Process[Task, O]

当process用户在stdin. 在这种情况下，可以等待进程中的当前计算结束，然后再结束进程本身。

我尝试了以下方法：

scala> :paste
// Entering paste mode (ctrl-D to finish)

import scalaz.{ -\/, \/-, \/ }
import scalaz.stream._
import scalaz.concurrent.Task

def haltOnUserInput[O](process: Process[Task, O]): Process[Task, O] = {
  process.either(io.stdInLines).flatMap {
    case -\/(o) => Process.emit(o)
    case \/-(_) => println("here"); Process.halt
  }
}

我正在这样测试：

scala> val oneSec = scala.concurrent.duration.Duration("1s")
oneSec: scala.concurrent.duration.Duration = 1 second

scala> val test = haltOnUserInput(Process.awakeEvery(oneSec)).take(10).map(_.toString).to(io.stdOutLines).run
test: scalaz.concurrent.Task[Unit] = scalaz.concurrent.Task@7a5e41bb

scala> test.run
1000144294 nanoseconds
2000148316 nanoseconds
here
3000130736 nanoseconds
here
4000124898 nanoseconds
5000189134 nanoseconds
6000201269 nanoseconds
here
7000127797 nanoseconds
8000132194 nanoseconds
9000191001 nanoseconds
10000126974 nanoseconds

如您所见，用户输入被确认（“这里”被打印了几次），但过程没有被中断。我不确定flatMapwrt 的行为是否符合预期Process.halt。

对如何haltOnUserInput正确书写有任何看法吗？

4

2 回答 2

4

另一种解决方案是使用 wye.interrupt：

val input = io.stdInLines.take(1).map(_ => true)
val dory = Process.awakeEvery(1.second).map(_ => println("Hi!"))
val process = input.wye(dory)(wye.interrupt)
process.run.run
于 2014-07-16T20:44:29.447 回答
1

这是我的haltOnUserInput实现：

  def haltOnUserInput[O](process: Process[Task, O]): Process[Task, O] = {
     val stop = Process.constant(()) either io.stdInLines map (_.isRight)
     process.until(stop)
   }
于 2014-07-16T20:07:34.103 回答