2 Object.defineProperty(exports, "__esModule", { value: true });
3 var isArray_1 = require("./util/isArray");
4 var isObject_1 = require("./util/isObject");
5 var isFunction_1 = require("./util/isFunction");
6 var UnsubscriptionError_1 = require("./util/UnsubscriptionError");
7 var Subscription = (function () {
8 function Subscription(unsubscribe) {
10 this._parentOrParents = null;
11 this._subscriptions = null;
13 this._unsubscribe = unsubscribe;
16 Subscription.prototype.unsubscribe = function () {
21 var _a = this, _parentOrParents = _a._parentOrParents, _unsubscribe = _a._unsubscribe, _subscriptions = _a._subscriptions;
23 this._parentOrParents = null;
24 this._subscriptions = null;
25 if (_parentOrParents instanceof Subscription) {
26 _parentOrParents.remove(this);
28 else if (_parentOrParents !== null) {
29 for (var index = 0; index < _parentOrParents.length; ++index) {
30 var parent_1 = _parentOrParents[index];
31 parent_1.remove(this);
34 if (isFunction_1.isFunction(_unsubscribe)) {
36 _unsubscribe.call(this);
39 errors = e instanceof UnsubscriptionError_1.UnsubscriptionError ? flattenUnsubscriptionErrors(e.errors) : [e];
42 if (isArray_1.isArray(_subscriptions)) {
44 var len = _subscriptions.length;
45 while (++index < len) {
46 var sub = _subscriptions[index];
47 if (isObject_1.isObject(sub)) {
52 errors = errors || [];
53 if (e instanceof UnsubscriptionError_1.UnsubscriptionError) {
54 errors = errors.concat(flattenUnsubscriptionErrors(e.errors));
64 throw new UnsubscriptionError_1.UnsubscriptionError(errors);
67 Subscription.prototype.add = function (teardown) {
68 var subscription = teardown;
70 return Subscription.EMPTY;
72 switch (typeof teardown) {
74 subscription = new Subscription(teardown);
76 if (subscription === this || subscription.closed || typeof subscription.unsubscribe !== 'function') {
79 else if (this.closed) {
80 subscription.unsubscribe();
83 else if (!(subscription instanceof Subscription)) {
84 var tmp = subscription;
85 subscription = new Subscription();
86 subscription._subscriptions = [tmp];
90 throw new Error('unrecognized teardown ' + teardown + ' added to Subscription.');
93 var _parentOrParents = subscription._parentOrParents;
94 if (_parentOrParents === null) {
95 subscription._parentOrParents = this;
97 else if (_parentOrParents instanceof Subscription) {
98 if (_parentOrParents === this) {
101 subscription._parentOrParents = [_parentOrParents, this];
103 else if (_parentOrParents.indexOf(this) === -1) {
104 _parentOrParents.push(this);
109 var subscriptions = this._subscriptions;
110 if (subscriptions === null) {
111 this._subscriptions = [subscription];
114 subscriptions.push(subscription);
118 Subscription.prototype.remove = function (subscription) {
119 var subscriptions = this._subscriptions;
121 var subscriptionIndex = subscriptions.indexOf(subscription);
122 if (subscriptionIndex !== -1) {
123 subscriptions.splice(subscriptionIndex, 1);
127 Subscription.EMPTY = (function (empty) {
130 }(new Subscription()));
133 exports.Subscription = Subscription;
134 function flattenUnsubscriptionErrors(errors) {
135 return errors.reduce(function (errs, err) { return errs.concat((err instanceof UnsubscriptionError_1.UnsubscriptionError) ? err.errors : err); }, []);
137 //# sourceMappingURL=Subscription.js.map