buffering

buffer (with chunks)

Stream('a', 'b', 'c').chunkLimit(1).unchunks.buffer(2).compile.toList

bufferAll (with chunks)

Stream('a', 'b', 'c').chunkLimit(1).unchunks.bufferAll.compile.toList

bufferBy (with chunks)

Stream('a', 'b', 'c').chunkLimit(1).unchunks.bufferBy(_ != 'b').compile.toList