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> > -
Converts the onData, on Done, and onError events into
StreamNotificationobjects that are passed into the downstream onData listener.