filtering

filter

Stream('a', 'b', 'c').filter(_ == 'b').compile.toList

filter (with chunks)

Stream('a', 'b', 'c').filter(_ == 'b').compile.toList

exists

Stream('a', 'b', 'c').exists(_ == 'b').compile.toList

exists (with chunks)

Stream('a', 'b', 'c').exists(_ == 'b').compile.toList

forall

Stream('a', 'b', 'c').forall(_ == 'b').compile.toList

forall (with chunks)

Stream('a', 'b', 'c').forall(_ == 'b').compile.toList

changes

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

changes (with chunks)

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