| /** PURE_IMPORTS_START .._observable_SubscribeOnObservable PURE_IMPORTS_END */ |
| import { SubscribeOnObservable } from '../observable/SubscribeOnObservable'; |
| /** |
| * Asynchronously subscribes Observers to this Observable on the specified IScheduler. |
| * |
| * <img src="./img/subscribeOn.png" width="100%"> |
| * |
| * @param {Scheduler} scheduler - The IScheduler to perform subscription actions on. |
| * @return {Observable<T>} The source Observable modified so that its subscriptions happen on the specified IScheduler. |
| . |
| * @method subscribeOn |
| * @owner Observable |
| */ |
| export function subscribeOn(scheduler, delay) { |
| if (delay === void 0) { |
| delay = 0; |
| } |
| return function subscribeOnOperatorFunction(source) { |
| return source.lift(new SubscribeOnOperator(scheduler, delay)); |
| }; |
| } |
| var SubscribeOnOperator = /*@__PURE__*/ (/*@__PURE__*/ function () { |
| function SubscribeOnOperator(scheduler, delay) { |
| this.scheduler = scheduler; |
| this.delay = delay; |
| } |
| SubscribeOnOperator.prototype.call = function (subscriber, source) { |
| return new SubscribeOnObservable(source, this.delay, this.scheduler).subscribe(subscriber); |
| }; |
| return SubscribeOnOperator; |
| }()); |
| //# sourceMappingURL=subscribeOn.js.map |