materialize method

Observable<Notification<T>> materialize ()

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

The Notification object contains the Kind of event (OnData, onDone, or OnError), and the item or error that was emitted. In the case of onDone, no data is emitted as part of the Notification.

Example: new Observable.just(1) .materialize() .listen((i) => print(i)); // Prints onData & onDone Notification

new Observable<int>.error(new Exception())
    .listen((i) => print(i)); // Prints onError Notification


Observable<Notification<T>> materialize() =>
    transform(new MaterializeStreamTransformer<T>());