- BREAKING: refactor!: make
onData
callback inemit.onEach
andemit.forEach
named - BREAKING: feat!: rename
emit.isCanceled
toemit.isDone
to encapsulate completion and cancelation - feat: introduce optional
onError
inemit.onEach
andemit.forEach
- feat: throw
AssertionError
whenemit
is called in a completedEventHandler
- feat: throw
AssertionError
whenemit.onEach
andemit.forEach
are unawaited - fix:
emit.onEach
andemit.forEach
error propagation when stream emits an error