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. [...]