Pytania oznaczone «iterate»

Scalaz iteratees: „Lifting” „EnumeratorT”, aby dopasować „IterateeT” do „większej” monady

Jeśli mam EnumeratorTodpowiedni odpowiednik IterateeT, mogę je uruchomić razem: val en: EnumeratorT[String, Task] = EnumeratorT.enumList(List("a", "b", "c")) val it: IterateeT[String, Task, Int] = IterateeT.length (it &= en).run : Task[Int] Jeśli monada modułu wyliczającego jest „większa”...

Unikanie wycieków pamięci dzięki Scalaz 7 zipWithIndex / group enumeratees

tło Jak wspomniano w tym pytaniu , używam iteracji Scalaz 7 do przetwarzania dużego (tj. Nieograniczonego) strumienia danych w stałej przestrzeni sterty. Mój kod wygląda tak: type ErrorOrT[M[+_], A] = EitherT[M, Throwable, A] type ErrorOr[A] = ErrorOrT[IO, A] def processChunk(c: Chunk, idx:...