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>

Methods

materialize() → Stream<StreamNotification<T>>

Converts the onData, on Done, and onError events into StreamNotification objects that are passed into the downstream onData listener.