Questions marquées «iterate»

Scalaz iteratees: «Lifting» «EnumeratorT» pour correspondre à «IterateeT» pour une monade «plus grosse»

Si j'ai un EnumeratorTet un correspondant, IterateeTje peux les exécuter ensemble: val en: EnumeratorT[String, Task] = EnumeratorT.enumList(List("a", "b", "c")) val it: IterateeT[String, Task, Int] = IterateeT.length (it &= en).run : Task[Int] Si la monade énumératrice est "plus grosse" que la...

Éviter les fuites de mémoire avec Scalaz 7 zipWithIndex / group enumeratees

Contexte Comme indiqué dans cette question , j'utilise Scalaz 7 iteratees pour traiter un grand flux de données (c'est-à-dire illimité) dans un espace de tas constant. Mon code ressemble à ceci: type ErrorOrT[M[+_], A] = EitherT[M, Throwable, A] type ErrorOr[A] = ErrorOrT[IO, A] def processChunk(c:...