DematerializeExtension<T> extension

Converts the onData, onDone, and onError Notifications from a materialized stream into normal onData, onDone, and onError events.

on

Methods

dematerialize() Stream<T>
Converts the onData, onDone, and onError Notification objects from a materialized stream into normal onData, onDone, and onError events.