DoneOnErrorStreamExtension<T> extension

Extends the Stream class with the ability to convert the source Stream to a Stream that emits done event on first error event. The error is included in the output of the returned Stream.

on

Methods

doneOnError([bool predicate(Object e, StackTrace s)?]) Stream<T>
Returns a Stream that emits done event on first error event. The error is included in the output of the returned Stream.