How to: Avoiding memory leaks with Scalaz 7 zipWithIndex/group enumeratees
Avoiding memory leaks with Scalaz 7 zipWithIndex/group enumeratees
Background
As noted in this question, I’m using Scalaz 7 iteratees to process a large (i.e., unbounded) stream of data in constant heap space.
My code looks like this:
type ErrorOrT[M[+_], A] = EitherT[M, Throwable, A] type ErrorOr[A] = ErrorOrT[IO, A] def processChunk(c: Chunk, idx: Long): Result def process(data:…
View On WordPress







