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>

Methods

materialize() → Stream<Notification<T>>

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