| 1 | /** PURE_IMPORTS_START tslib,_scheduler_async,_util_isDate,_innerSubscribe PURE_IMPORTS_END */
|
|---|
| 2 | import * as tslib_1 from "tslib";
|
|---|
| 3 | import { async } from '../scheduler/async';
|
|---|
| 4 | import { isDate } from '../util/isDate';
|
|---|
| 5 | import { SimpleOuterSubscriber, innerSubscribe, SimpleInnerSubscriber } from '../innerSubscribe';
|
|---|
| 6 | export function timeoutWith(due, withObservable, scheduler) {
|
|---|
| 7 | if (scheduler === void 0) {
|
|---|
| 8 | scheduler = async;
|
|---|
| 9 | }
|
|---|
| 10 | return function (source) {
|
|---|
| 11 | var absoluteTimeout = isDate(due);
|
|---|
| 12 | var waitFor = absoluteTimeout ? (+due - scheduler.now()) : Math.abs(due);
|
|---|
| 13 | return source.lift(new TimeoutWithOperator(waitFor, absoluteTimeout, withObservable, scheduler));
|
|---|
| 14 | };
|
|---|
| 15 | }
|
|---|
| 16 | var TimeoutWithOperator = /*@__PURE__*/ (function () {
|
|---|
| 17 | function TimeoutWithOperator(waitFor, absoluteTimeout, withObservable, scheduler) {
|
|---|
| 18 | this.waitFor = waitFor;
|
|---|
| 19 | this.absoluteTimeout = absoluteTimeout;
|
|---|
| 20 | this.withObservable = withObservable;
|
|---|
| 21 | this.scheduler = scheduler;
|
|---|
| 22 | }
|
|---|
| 23 | TimeoutWithOperator.prototype.call = function (subscriber, source) {
|
|---|
| 24 | return source.subscribe(new TimeoutWithSubscriber(subscriber, this.absoluteTimeout, this.waitFor, this.withObservable, this.scheduler));
|
|---|
| 25 | };
|
|---|
| 26 | return TimeoutWithOperator;
|
|---|
| 27 | }());
|
|---|
| 28 | var TimeoutWithSubscriber = /*@__PURE__*/ (function (_super) {
|
|---|
| 29 | tslib_1.__extends(TimeoutWithSubscriber, _super);
|
|---|
| 30 | function TimeoutWithSubscriber(destination, absoluteTimeout, waitFor, withObservable, scheduler) {
|
|---|
| 31 | var _this = _super.call(this, destination) || this;
|
|---|
| 32 | _this.absoluteTimeout = absoluteTimeout;
|
|---|
| 33 | _this.waitFor = waitFor;
|
|---|
| 34 | _this.withObservable = withObservable;
|
|---|
| 35 | _this.scheduler = scheduler;
|
|---|
| 36 | _this.scheduleTimeout();
|
|---|
| 37 | return _this;
|
|---|
| 38 | }
|
|---|
| 39 | TimeoutWithSubscriber.dispatchTimeout = function (subscriber) {
|
|---|
| 40 | var withObservable = subscriber.withObservable;
|
|---|
| 41 | subscriber._unsubscribeAndRecycle();
|
|---|
| 42 | subscriber.add(innerSubscribe(withObservable, new SimpleInnerSubscriber(subscriber)));
|
|---|
| 43 | };
|
|---|
| 44 | TimeoutWithSubscriber.prototype.scheduleTimeout = function () {
|
|---|
| 45 | var action = this.action;
|
|---|
| 46 | if (action) {
|
|---|
| 47 | this.action = action.schedule(this, this.waitFor);
|
|---|
| 48 | }
|
|---|
| 49 | else {
|
|---|
| 50 | this.add(this.action = this.scheduler.schedule(TimeoutWithSubscriber.dispatchTimeout, this.waitFor, this));
|
|---|
| 51 | }
|
|---|
| 52 | };
|
|---|
| 53 | TimeoutWithSubscriber.prototype._next = function (value) {
|
|---|
| 54 | if (!this.absoluteTimeout) {
|
|---|
| 55 | this.scheduleTimeout();
|
|---|
| 56 | }
|
|---|
| 57 | _super.prototype._next.call(this, value);
|
|---|
| 58 | };
|
|---|
| 59 | TimeoutWithSubscriber.prototype._unsubscribe = function () {
|
|---|
| 60 | this.action = undefined;
|
|---|
| 61 | this.scheduler = null;
|
|---|
| 62 | this.withObservable = null;
|
|---|
| 63 | };
|
|---|
| 64 | return TimeoutWithSubscriber;
|
|---|
| 65 | }(SimpleOuterSubscriber));
|
|---|
| 66 | //# sourceMappingURL=timeoutWith.js.map
|
|---|
