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

Question

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

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

我想转换函数

    reqDoc(id:A):Task[B]

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

    reqDoc:Process1[A,B]

Answer 1

我认为您不想要 a Process1，我认为如果您从中创建 a ，Process1您将创建 a Process1[A, Task[B]]，这不是您想要的。

我认为您想创建一个Channel可以附加的Process，这会给您一个新的Process. AChannel只是Process产生有效功能的 a 的别名。

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)