202 lines
9.5 KiB
JavaScript
202 lines
9.5 KiB
JavaScript
|
'use strict';
|
||
|
|
/**
|
||
|
|
* @license Angular v<unknown>
|
||
|
|
* (c) 2010-2022 Google LLC. https://angular.io/
|
||
|
|
* License: MIT
|
||
|
|
*/
|
||
|
|
(function (global, factory) {
|
||
|
|
typeof exports === 'object' && typeof module !== 'undefined' ? factory(require('rxjs')) :
|
||
|
|
typeof define === 'function' && define.amd ? define(['rxjs'], factory) :
|
||
|
|
(global = typeof globalThis !== 'undefined' ? globalThis : global || self, factory(global.rxjs));
|
||
|
|
})(this, (function (rxjs) {
|
||
|
|
'use strict';
|
||
|
|
Zone.__load_patch('rxjs', function (global, Zone, api) {
|
||
|
|
var symbol = Zone.__symbol__;
|
||
|
|
var nextSource = 'rxjs.Subscriber.next';
|
||
|
|
var errorSource = 'rxjs.Subscriber.error';
|
||
|
|
var completeSource = 'rxjs.Subscriber.complete';
|
||
|
|
var ObjectDefineProperties = Object.defineProperties;
|
||
|
|
var patchObservable = function () {
|
||
|
|
var ObservablePrototype = rxjs.Observable.prototype;
|
||
|
|
var _symbolSubscribe = symbol('_subscribe');
|
||
|
|
var _subscribe = ObservablePrototype[_symbolSubscribe] = ObservablePrototype._subscribe;
|
||
|
|
ObjectDefineProperties(rxjs.Observable.prototype, {
|
||
|
|
_zone: { value: null, writable: true, configurable: true },
|
||
|
|
_zoneSource: { value: null, writable: true, configurable: true },
|
||
|
|
_zoneSubscribe: { value: null, writable: true, configurable: true },
|
||
|
|
source: {
|
||
|
|
configurable: true,
|
||
|
|
get: function () {
|
||
|
|
return this._zoneSource;
|
||
|
|
},
|
||
|
|
set: function (source) {
|
||
|
|
this._zone = Zone.current;
|
||
|
|
this._zoneSource = source;
|
||
|
|
}
|
||
|
|
},
|
||
|
|
_subscribe: {
|
||
|
|
configurable: true,
|
||
|
|
get: function () {
|
||
|
|
if (this._zoneSubscribe) {
|
||
|
|
return this._zoneSubscribe;
|
||
|
|
}
|
||
|
|
else if (this.constructor === rxjs.Observable) {
|
||
|
|
return _subscribe;
|
||
|
|
}
|
||
|
|
var proto = Object.getPrototypeOf(this);
|
||
|
|
return proto && proto._subscribe;
|
||
|
|
},
|
||
|
|
set: function (subscribe) {
|
||
|
|
this._zone = Zone.current;
|
||
|
|
if (!subscribe) {
|
||
|
|
this._zoneSubscribe = subscribe;
|
||
|
|
}
|
||
|
|
else {
|
||
|
|
this._zoneSubscribe = function () {
|
||
|
|
if (this._zone && this._zone !== Zone.current) {
|
||
|
|
var tearDown_1 = this._zone.run(subscribe, this, arguments);
|
||
|
|
if (typeof tearDown_1 === 'function') {
|
||
|
|
var zone_1 = this._zone;
|
||
|
|
return function () {
|
||
|
|
if (zone_1 !== Zone.current) {
|
||
|
|
return zone_1.run(tearDown_1, this, arguments);
|
||
|
|
}
|
||
|
|
return tearDown_1.apply(this, arguments);
|
||
|
|
};
|
||
|
|
}
|
||
|
|
else {
|
||
|
|
return tearDown_1;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
else {
|
||
|
|
return subscribe.apply(this, arguments);
|
||
|
|
}
|
||
|
|
};
|
||
|
|
}
|
||
|
|
}
|
||
|
|
},
|
||
|
|
subjectFactory: {
|
||
|
|
get: function () {
|
||
|
|
return this._zoneSubjectFactory;
|
||
|
|
},
|
||
|
|
set: function (factory) {
|
||
|
|
var zone = this._zone;
|
||
|
|
this._zoneSubjectFactory = function () {
|
||
|
|
if (zone && zone !== Zone.current) {
|
||
|
|
return zone.run(factory, this, arguments);
|
||
|
|
}
|
||
|
|
return factory.apply(this, arguments);
|
||
|
|
};
|
||
|
|
}
|
||
|
|
}
|
||
|
|
});
|
||
|
|
};
|
||
|
|
api.patchMethod(rxjs.Observable.prototype, 'lift', function (delegate) { return function (self, args) {
|
||
|
|
var observable = delegate.apply(self, args);
|
||
|
|
if (observable.operator) {
|
||
|
|
observable.operator._zone = Zone.current;
|
||
|
|
api.patchMethod(observable.operator, 'call', function (operatorDelegate) { return function (operatorSelf, operatorArgs) {
|
||
|
|
if (operatorSelf._zone && operatorSelf._zone !== Zone.current) {
|
||
|
|
return operatorSelf._zone.run(operatorDelegate, operatorSelf, operatorArgs);
|
||
|
|
}
|
||
|
|
return operatorDelegate.apply(operatorSelf, operatorArgs);
|
||
|
|
}; });
|
||
|
|
}
|
||
|
|
return observable;
|
||
|
|
}; });
|
||
|
|
var patchSubscription = function () {
|
||
|
|
ObjectDefineProperties(rxjs.Subscription.prototype, {
|
||
|
|
_zone: { value: null, writable: true, configurable: true },
|
||
|
|
_zoneUnsubscribe: { value: null, writable: true, configurable: true },
|
||
|
|
_unsubscribe: {
|
||
|
|
get: function () {
|
||
|
|
if (this._zoneUnsubscribe || this._zoneUnsubscribeCleared) {
|
||
|
|
return this._zoneUnsubscribe;
|
||
|
|
}
|
||
|
|
var proto = Object.getPrototypeOf(this);
|
||
|
|
return proto && proto._unsubscribe;
|
||
|
|
},
|
||
|
|
set: function (unsubscribe) {
|
||
|
|
this._zone = Zone.current;
|
||
|
|
if (!unsubscribe) {
|
||
|
|
this._zoneUnsubscribe = unsubscribe;
|
||
|
|
// In some operator such as `retryWhen`, the _unsubscribe
|
||
|
|
// method will be set to null, so we need to set another flag
|
||
|
|
// to tell that we should return null instead of finding
|
||
|
|
// in the prototype chain.
|
||
|
|
this._zoneUnsubscribeCleared = true;
|
||
|
|
}
|
||
|
|
else {
|
||
|
|
this._zoneUnsubscribeCleared = false;
|
||
|
|
this._zoneUnsubscribe = function () {
|
||
|
|
if (this._zone && this._zone !== Zone.current) {
|
||
|
|
return this._zone.run(unsubscribe, this, arguments);
|
||
|
|
}
|
||
|
|
else {
|
||
|
|
return unsubscribe.apply(this, arguments);
|
||
|
|
}
|
||
|
|
};
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
});
|
||
|
|
};
|
||
|
|
var patchSubscriber = function () {
|
||
|
|
var next = rxjs.Subscriber.prototype.next;
|
||
|
|
var error = rxjs.Subscriber.prototype.error;
|
||
|
|
var complete = rxjs.Subscriber.prototype.complete;
|
||
|
|
Object.defineProperty(rxjs.Subscriber.prototype, 'destination', {
|
||
|
|
configurable: true,
|
||
|
|
get: function () {
|
||
|
|
return this._zoneDestination;
|
||
|
|
},
|
||
|
|
set: function (destination) {
|
||
|
|
this._zone = Zone.current;
|
||
|
|
this._zoneDestination = destination;
|
||
|
|
}
|
||
|
|
});
|
||
|
|
// patch Subscriber.next to make sure it run
|
||
|
|
// into SubscriptionZone
|
||
|
|
rxjs.Subscriber.prototype.next = function () {
|
||
|
|
var currentZone = Zone.current;
|
||
|
|
var subscriptionZone = this._zone;
|
||
|
|
// for performance concern, check Zone.current
|
||
|
|
// equal with this._zone(SubscriptionZone) or not
|
||
|
|
if (subscriptionZone && subscriptionZone !== currentZone) {
|
||
|
|
return subscriptionZone.run(next, this, arguments, nextSource);
|
||
|
|
}
|
||
|
|
else {
|
||
|
|
return next.apply(this, arguments);
|
||
|
|
}
|
||
|
|
};
|
||
|
|
rxjs.Subscriber.prototype.error = function () {
|
||
|
|
var currentZone = Zone.current;
|
||
|
|
var subscriptionZone = this._zone;
|
||
|
|
// for performance concern, check Zone.current
|
||
|
|
// equal with this._zone(SubscriptionZone) or not
|
||
|
|
if (subscriptionZone && subscriptionZone !== currentZone) {
|
||
|
|
return subscriptionZone.run(error, this, arguments, errorSource);
|
||
|
|
}
|
||
|
|
else {
|
||
|
|
return error.apply(this, arguments);
|
||
|
|
}
|
||
|
|
};
|
||
|
|
rxjs.Subscriber.prototype.complete = function () {
|
||
|
|
var currentZone = Zone.current;
|
||
|
|
var subscriptionZone = this._zone;
|
||
|
|
// for performance concern, check Zone.current
|
||
|
|
// equal with this._zone(SubscriptionZone) or not
|
||
|
|
if (subscriptionZone && subscriptionZone !== currentZone) {
|
||
|
|
return subscriptionZone.run(complete, this, arguments, completeSource);
|
||
|
|
}
|
||
|
|
else {
|
||
|
|
return complete.call(this);
|
||
|
|
}
|
||
|
|
};
|
||
|
|
};
|
||
|
|
patchObservable();
|
||
|
|
patchSubscription();
|
||
|
|
patchSubscriber();
|
||
|
|
});
|
||
|
|
}));
|