451

如果我有一个EnumeratorT和一个对应的，IterateeT我可以一起运行它们：

val en: EnumeratorT[String, Task] = EnumeratorT.enumList(List("a", "b", "c"))
val it: IterateeT[String, Task, Int] = IterateeT.length

(it &= en).run : Task[Int]

如果 enumerator monad 比 iteratee monad“大”，我可以使用up或更一般地说，Hoist“提升” iteratee 以匹配：

val en: EnumeratorT[String, Task] = ...
val it: IterateeT[String, Id, Int] = ...

val liftedIt = IterateeT.IterateeTMonadTrans[String].hoist(
  implicitly[Task |>=| Id]).apply(it)
(liftedIt &= en).run: Task[Int]

但是当 iteratee monad 比 enumerator monad“大”时我该怎么办？

val en: EnumeratorT[String, Id] = ...
val it: IterateeT[String, Task, Int] = ...

it &= ???

似乎没有一个Hoist实例EnumeratorT，也没有任何明显的“提升”方法。

4

1 回答 1

6

在通常的编码中，枚举器本质上是一个StepT[E, F, ?] ~> F[StepT[E, F, ?]]. 如果您尝试编写一个通用方法将此类型转换为Step[E, G, ?] ~> G[Step[E, G, ?]]给定的 an F ~> G，您将很快遇到一个问题：您需要将 a “降低”Step[E, G, A]到 aStep[E, F, A]以便能够应用原始枚举器。

Scalaz 还提供了另一种枚举器编码，如下所示：

trait EnumeratorP[E, F[_]] {
  def apply[G[_]: Monad](f: F ~> G): EnumeratorT[E, G]
}

这种方法允许我们定义一个特定于它需要的效果的枚举器，但可以“提升”它以与需要更丰富上下文的消费者一起使用。我们可以修改您的示例以使用EnumeratorP（以及更新的自然转换方法而不是旧的 monad 偏序）：

import scalaz._, Scalaz._, iteratee._, concurrent.Task

def enum: EnumeratorP[String, Id] = ???
def iter: IterateeT[String, Task, Int] = ???

val toTask = new (Id ~> Task) { def apply[A](a: A): Task[A] = Task(a) }

我们现在可以像这样组合这两个：

scala> def result = (iter &= enum(toTask)).run
result: scalaz.concurrent.Task[Int]

EnumeratorP是一元的（如果F是适用的），并且EnumeratorP伴随对象提供了一些函数来帮助定义看起来很像的枚举器EnumeratorT-there's empty, perform,enumPStream等。我想必须有一些EnumeratorT实例无法使用编码，EnumeratorP但我不知道它们会是什么样子。

于 2019-09-28T15:47:36.250 回答