Pertanyaan yang diberi tag iterate

Scalaz iteratees: “Lifting” `EnumeratorT` untuk mencocokkan` IterateeT` untuk monad “lebih besar”

Jika saya punya EnumeratorTdan yang sesuai IterateeTsaya bisa menjalankannya bersama-sama: val en: EnumeratorT[String, Task] = EnumeratorT.enumList(List("a", "b", "c")) val it: IterateeT[String, Task, Int] = IterateeT.length (it &= en).run : Task[Int] Jika enumerator monad "lebih besar"...

Menghindari kebocoran memori dengan Scalaz 7 zipWithIndex / group enumeratees

Latar Belakang Seperti disebutkan dalam pertanyaan ini , saya menggunakan Scalaz 7 iterasi untuk memproses aliran data yang besar (yaitu, tak terbatas) dalam ruang heap konstan. Kode saya terlihat seperti ini: type ErrorOrT[M[+_], A] = EitherT[M, Throwable, A] type ErrorOr[A] = ErrorOrT[IO,...