Sha256: fdaee64d53a4d17235a9dea16da1bc1303b2b47e8f41fb7fe39188160ae1a8b8
Contents?: true
Size: 731 Bytes
Versions: 14
Compression:
Stored size: 731 Bytes
Contents
/**
* Wraps the source sequence in order to run its observer callbacks on the specified scheduler.
*
* This only invokes observer callbacks on a scheduler. In case the subscription and/or unsubscription actions have side-effects
* that require to be run on a scheduler, use subscribeOn.
*
* @param {Scheduler} scheduler Scheduler to notify observers on.
* @returns {Observable} The source sequence whose observations happen on the specified scheduler.
*/
observableProto.observeOn = function (scheduler) {
var source = this;
return new AnonymousObservable(function (observer) {
return source.subscribe(new ObserveOnObserver(scheduler, observer));
}, source);
};
Version data entries
14 entries across 7 versions & 1 rubygems