Lines Matching refs:subscription
20 var cleanupSubscription = function (subscription) { argument
21 var cleanup = subscription._c;
23 subscription._c = undefined;
28 var subscriptionClosed = function (subscription) { argument
29 return subscription._o === undefined;
32 var closeSubscription = function (subscription) { argument
33 if (!subscriptionClosed(subscription)) {
34 subscription._o = undefined;
35 cleanupSubscription(subscription);
46 var subscription = cleanup;
48 …if (typeof cleanup.unsubscribe === 'function') cleanup = function () { subscription.unsubscribe();…
62 var SubscriptionObserver = function (subscription) { argument
63 this._s = subscription;
68 var subscription = this._s;
69 if (!subscriptionClosed(subscription)) {
70 var observer = subscription._o;
76 closeSubscription(subscription);
84 var subscription = this._s;
85 if (subscriptionClosed(subscription)) throw value;
86 var observer = subscription._o;
87 subscription._o = undefined;
94 cleanupSubscription(subscription);
98 } cleanupSubscription(subscription);
102 var subscription = this._s;
103 if (!subscriptionClosed(subscription)) {
104 var observer = subscription._o;
105 subscription._o = undefined;
111 cleanupSubscription(subscription);
115 } cleanupSubscription(subscription);
133 var subscription = that.subscribe({
139 subscription.unsubscribe();