whereNotNull method

Stream<T> whereNotNull()

Discards null events from this stream.

If the source stream is a broadcast stream the result will be as well.

Errors from the source stream are forwarded directly to the result stream.

Implementation

Stream<T> whereNotNull() => transformByHandlers(onData: (event, sink) {
      if (event != null) sink.add(event);
    });