MaterializeExtension<T> extension
Extends the Stream class with the ability to convert the onData, on Done, and onError events into Notifications that are passed into the downstream onData listener.
- on
-
- Stream<
T>
- Stream<
Methods
-
materialize(
) → Stream< Notification< T> > - Converts the onData, on Done, and onError events into Notification objects that are passed into the downstream onData listener.