停止在用户输入

我试图写入以下功能停止在用户输入

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

在用户发送上stdin一行其停止process一个Process [任务，O]。在这种情况下，可以在结束进程本身之前等待进程中的当前计算结束。

我曾尝试以下：

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] = [email protected] 

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

正如你所看到的，用户的输入被确认（“这里”被打印出来，好几次）但过程不会中断。我不确定flatMap的行为如预期那样Process.halt。

任何关于如何正确书写haltOnUserInput？

来源

2014-07-16 betehess

什么 – Daenyth

@Daenyth我已经作出了明确的问题，这里实际的问题：如何正确写入'haltOnUserInput'？ – betehess

另一种解决方案是使用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-16 20:44:29 tixxit

很好！顺便说一下，'.take（1）'在这里没用。 – betehess

这个答案帮助了我，谢谢。可能需要此更改：http://stackoverflow.com/questions/32852039/why-awakeevery-was-removed-from-scalaz-stream –

这是我实现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-16 20:07:34

停止在用户输入

回答

相关问题