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