take

fewer

Stream('a', 'b', 'c').take(2).compile.toList

fewer (with chunks)

Stream('a', 'b', 'c').take(2).compile.toList

more

Stream('a', 'b', 'c').take(5).compile.toList

more (with chunks)

Stream('a', 'b', 'c').take(5).compile.toList

from an infinite stream

Stream('a').repeat.take(2).compile.toList

from an infinite stream (with chunks)

Stream('a').repeat.take(2).compile.toList

from a drained stream

Stream('a', 'b', 'c').drain.take(2).compile.toList

from a drained stream (with chunks)

Stream('a', 'b', 'c').drain.take(2).compile.toList