如果我有一个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]
如果枚举对象的单子比被迭代对象的单子“大”，我可以使用up或更一般的Hoist来“提升”被迭代对象以匹配:
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]
但是，当迭代者单子比枚举者单子“更大”时，我该怎么办?
val en: EnumeratorT[String, Id] = ...
val it: IterateeT[String, Task, Int] = ...
it &= ???
似乎没有EnumeratorT的Hoist实例，也没有任何明显的“lift”方法。
在通常的编码中，枚举数本质上是一个step [E, F， ?] ~> F[step [E, F， ?]]。如果您尝试编写一个泛型方法，将此类型转换为给定F ~> G的Step[E, G， ?] ~> G[Step[E, G， ?]]，那么您很快就会遇到一个问题:您需要将Step[E, G, a]“降低”为Step[E, F, a]，以便能够应用原始枚举数。
Scalaz还提供了另一种枚举数编码，看起来像这样:
trait EnumeratorP[E, F[_]] {
def apply[G[_]: Monad](f: F ~> G): EnumeratorT[E, G]
}
这种方法允许我们定义一个特定于它所需要的效果的枚举器，但是可以“提升”它以与需要更丰富上下文的消费者一起工作。我们可以修改你的例子，使用EnumeratorP(和更新的自然转换方法，而不是旧的单子偏序):
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上的枚举数非常相似的枚举数——有empty、perform、enumPStream等。我猜一定有EnumeratorT实例不能使用EnumeratorP编码实现，但我不确定它们会是什么样子。
在通常的编码中，枚举数本质上是一个step [E, F， ?] ~> F[step [E, F， ?]]。如果您尝试编写一个泛型方法，将此类型转换为给定F ~> G的Step[E, G， ?] ~> G[Step[E, G， ?]]，那么您很快就会遇到一个问题:您需要将Step[E, G, a]“降低”为Step[E, F, a]，以便能够应用原始枚举数。
Scalaz还提供了另一种枚举数编码，看起来像这样:
trait EnumeratorP[E, F[_]] {
def apply[G[_]: Monad](f: F ~> G): EnumeratorT[E, G]
}
这种方法允许我们定义一个特定于它所需要的效果的枚举器，但是可以“提升”它以与需要更丰富上下文的消费者一起工作。我们可以修改你的例子，使用EnumeratorP(和更新的自然转换方法，而不是旧的单子偏序):
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上的枚举数非常相似的枚举数——有empty、perform、enumPStream等。我猜一定有EnumeratorT实例不能使用EnumeratorP编码实现，但我不确定它们会是什么样子。
