使用 Scalaz 流，如何将 A => Task[B] 转换为 Process1[A,B]答案

【问题标题】：Using Scalaz stream, how to convert A => Task[B] to Process1[A,B]使用 Scalaz 流，如何将 A => Task[B] 转换为 Process1[A,B]
【发布时间】：2014-08-20 07:48:58
【问题描述】：

我正在将一个对远程服务器的 http 请求编码为一个函数，该函数接受一个 id 并产生一个 Task[JValue]。

我想将该函数转换为 Process1，以简化我的程序（通过简化，我的意思是尽可能使用 Processes 作为构建块）

我想转换函数

    reqDoc(id:A):Task[B]

（其中 A 是 Id 的类型，B 是响应的类型）进入

    reqDoc:Process1[A,B]

【问题讨论】：

标签： scala scalaz scalaz-stream

【解决方案1】：

我不认为你想要一个 Process1，我认为如果你创建一个 Process1 ，你会创建一个 Process1[A, Task[B]] 这不是你想要的。

我认为您想创建一个Channel，您可以将Process 附加到它上面，这将为您提供一个新的Process。 Channel 只是产生有效功能的 Process 的别名。

type Channel[+F[_],-I,O] = Process[F, I => F[O]]

既然你有一个函数，你只需要创建一个进程来产生相同函数的无限流，constant

// a String => Task[Int] that we'll make a channel from
val length: String => Task[Int] = (x => Task.delay(x.length))
// a channel is just a source of functions:
val lengthChannel = Process.constant(length)

现在给定一个产生字符串的进程（这里我们只产生一个）：

val source: Process[Task,String] = Process.emit("asdf")

我们可以通过我们的渠道运行我们的源来创建一个进程

val lengths = source through lengthChannel

我们可以运行我们的进程并获得“asdf”的长度

scala> lengths.runLog.run
res5: scala.collection.immutable.IndexedSeq[Int] = Vector(4)

【讨论】：