raising errors

raiseError

(Stream.raiseError[IO](Err) ++ Stream('a')).compile.toList

raiseError (with chunks)

(Stream.raiseError[IO](Err) ++ Stream('a')).compile.toList

in evalMap

Stream('a', 'b', 'c').evalMap(x => IO.raiseWhen(x == 'b')(Err)).compile.toList

in evalMap (with chunks)

Stream('a', 'b', 'c').evalMap(x => IO.raiseWhen(x == 'b')(Err)).compile.toList

propagation

Stream('a', 'b', 'c')
  .evalMap(x => IO.raiseWhen(x == 'b')(Err))
  .map(identity)
  .compile
  .toList

propagation (with chunks)

Stream('a', 'b', 'c')
  .evalMap(x => IO.raiseWhen(x == 'b')(Err))
  .map(identity)
  .compile
  .toList