Sha256: 62452d96b54c52820cca78c01169569bc99d904a9b9a82e5aac40928f81f10aa
Contents?: true
Size: 747 Bytes
Versions: 14
Compression:
Stored size: 747 Bytes
Contents
/**
* Materializes the implicit notifications of an observable sequence as explicit notification values.
* @returns {Observable} An observable sequence containing the materialized notification values from the source sequence.
*/
observableProto.materialize = function () {
var source = this;
return new AnonymousObservable(function (observer) {
return source.subscribe(function (value) {
observer.onNext(notificationCreateOnNext(value));
}, function (e) {
observer.onNext(notificationCreateOnError(e));
observer.onCompleted();
}, function () {
observer.onNext(notificationCreateOnCompleted());
observer.onCompleted();
});
}, source);
};
Version data entries
14 entries across 7 versions & 1 rubygems