lmm*_*lmm 445 monads scala enumerator scalaz iterate
如果我有一个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]
Run Code Online (Sandbox Code Playgroud)
如果枚举器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]
Run Code Online (Sandbox Code Playgroud)
但是,当iteratee monad比枚举器monad"更大"时,我该怎么办?
val en: EnumeratorT[String, Id] = ...
val it: IterateeT[String, Task, Int] = ...
it &= ???
Run Code Online (Sandbox Code Playgroud)
似乎没有任何Hoist实例EnumeratorT,也没有任何明显的"提升"方法.
在通常的编码中,枚举器本质上是一个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]
}
Run Code Online (Sandbox Code Playgroud)
这种方法允许我们定义一个枚举器,它特定于它需要的效果,但可以“提升”以与需要更丰富上下文的消费者一起工作。我们可以修改您的示例以使用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) }
Run Code Online (Sandbox Code Playgroud)
我们现在可以像这样组合两者:
scala> def result = (iter &= enum(toTask)).run
result: scalaz.concurrent.Task[Int]
Run Code Online (Sandbox Code Playgroud)
EnumeratorP是一元(如果F是应用性),和EnumeratorP同伴对象提供了一些功能,以帮助确定该统计员看起来很像上的那些EnumeratorT-there的empty,perform,enumPStream等我想有必须EnumeratorT是不能使用执行情况该EnumeratorP编码,但是从我的头顶,我不知道他们是什么样子。