Als «iterate» getaggte Fragen

Scalaz iteriert: "Heben" von "EnumeratorT", um "IterateeT" für eine "größere" Monade zu finden

Wenn ich ein EnumeratorTund ein entsprechendes IterateeThabe, kann ich sie zusammen ausführen: val en: EnumeratorT[String, Task] = EnumeratorT.enumList(List("a", "b", "c")) val it: IterateeT[String, Task, Int] = IterateeT.length (it &= en).run : Task[Int] Wenn die Enumerator-Monade "größer" als...

Vermeiden von Speicherlecks mit Scalaz 7 zipWithIndex / group enumeratees

Hintergrund Wie in dieser Frage erwähnt , verwende ich Scalaz 7-Iterate, um einen großen (dh unbegrenzten) Datenstrom in einem konstanten Heap-Raum zu verarbeiten. Mein Code sieht folgendermaßen aus: type ErrorOrT[M[+_], A] = EitherT[M, Throwable, A] type ErrorOr[A] = ErrorOrT[IO, A] def...