如何將Scalaz-Stream Process [F，Option [T]]轉換爲Process [F，T]？

Question

我有一個scalaz流過程：

val src = Process.repeatEval(Task(in.take())) : Process[Task, Option[T]] 

如何擺脫期權？

到目前爲止，我已經使用收集，但給人的感覺並不優雅：

src.collect { case Some(x) => x } : Process[Task, T] 

有沒有更好的辦法？

Answer 1

你的解決方案是正確的，但是實現在scalaz流（< = 0.8）已經存在，在process1.stripNone：

src.pipe(process1.stripNone) 

或

src |> process1.stripNone 

許多其它變換（可能是有狀態）在process1中定義，因此值得通過文件查找可能有用的轉換。