mapStream consumes an entire chunk even if the inner iteratee doesn't

[anonymous]

mapStream maps elements one chunk at a time. If the inner iteratee only consumes part of the chunk, the remainder is discarded. The desired behavior would be to have mapStream only consume as much input as necessary for the inner iteratee.

Example:

Prelude Data.Iteratee> enumPureNChunk [1..10] 4 (joinI (mapStream (*2) Data.Iteratee.head) >> stream2stream) >>= run [5,6,7,8,9,10] Prelude Data.Iteratee>