createOnNext
Creates an object that represents an OnNext notification to an observer.
Arguments
value
(Any): The value contained in the notification.
Returns
(Notification): The OnNext notification containing the value.
var source = Rx.Observable
.fromArray([
Rx.Notification.createOnNext(42),
Rx.Notification.createOnCompleted()
])
.dematerialize();
var subscription = source.subscribe(
x => console.log(`onNext: ${x}`),
e => console.log(`onError: ${e}`),
() => console.log('onCompleted'));
// => onNext: 42
// => onCompleted
Example
Last updated
Was this helpful?