completeOnError method

Stream<T> completeOnError()

Completes the stream immediately upon an error, swallowing the error.

Example:

myStream.completeOnError()
  .listen(print, onError: (e) => print('Error handled silently'));

Implementation

Stream<T> completeOnError() {
  return transform(
    StreamTransformer<T, T>.fromHandlers(
      handleError: (error, stackTrace, sink) {
        sink.close();
      },
    ),
  );
}