compile

toList

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

diagram

toList (with chunks)

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

diagram

drain

Stream('a', 'b', 'c').compile.drain

diagram

drain (with chunks)

Stream('a', 'b', 'c').compile.drain

diagram

last

Stream('a', 'b', 'c').compile.last

diagram

last (with chunks)

Stream('a', 'b', 'c').compile.last

diagram

count

Stream('a', 'b', 'c').compile.count

diagram

count (with chunks)

Stream('a', 'b', 'c').compile.count

diagram

onlyOrError

Stream('a', 'b', 'c').compile.onlyOrError

diagram

onlyOrError (with chunks)

Stream('a', 'b', 'c').compile.onlyOrError

diagram