Scalaz迭代：“举起” EnumeratorT以匹配“ IterateeT”以获得“更大”的单子组

Question

如果我有一个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]

如果枚举数单子比iteratee单子“更大”，我可以使用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比枚举器monad“大”时，我该怎么办？

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

it &= ???

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

Answer 1

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

Scalaz还提供了如下所示的an alternative enumerator encoding：

trait EnumeratorP[E, F[_]] { =>
  def apply[G[_]: Monad](trans: 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上的枚举数的函数-empty，[ C0]，perform等。我想必须存在无法使用enumPStream编码实现的EnumeratorT实例，但是我不敢确定它们的外观。