merge

merge

Stream('a').merge(Stream('b')).compile.toList

merge (with chunks)

Stream('a').merge(Stream('b')).compile.toList

parZip

Stream('a', 'b', 'c').parZip(Stream('d', 'e')).compile.drain

parZip (with chunks)

Stream('a', 'b', 'c').parZip(Stream('d', 'e')).compile.drain