Sha256: 7ce0e086dd2989d370dc971bb8f9f47b610716ade5876ada2f3df8a0dd4f9cbf
Contents?: true
Size: 840 Bytes
Versions: 14
Compression:
Stored size: 840 Bytes
Contents
/**
* Supports push-style iteration over an observable sequence.
*/
var Observer = Rx.Observer = function () { };
/**
* Creates an observer from the specified OnNext, along with optional OnError, and OnCompleted actions.
* @param {Function} [onNext] Observer's OnNext action implementation.
* @param {Function} [onError] Observer's OnError action implementation.
* @param {Function} [onCompleted] Observer's OnCompleted action implementation.
* @returns {Observer} The observer object implemented using the given actions.
*/
var observerCreate = Observer.create = function (onNext, onError, onCompleted) {
onNext || (onNext = noop);
onError || (onError = defaultError);
onCompleted || (onCompleted = noop);
return new AnonymousObserver(onNext, onError, onCompleted);
};
Version data entries
14 entries across 7 versions & 1 rubygems