| /dports/textproc/write-good/write-good-1.0.8/node_modules/rxjs/src/internal/operators/ |
| H A D | switchMap.ts | 110 private innerSubscription?: Subscription;
130 const innerSubscription = this.innerSubscription; constant
131 if (innerSubscription) {
132 innerSubscription.unsubscribe();
137 this.innerSubscription = innerSubscribe(result, innerSubscriber);
141 if (this.innerSubscription !== innerSubscriber) {
142 destination.add(this.innerSubscription);
147 const {innerSubscription} = this; constant
148 if (!innerSubscription || innerSubscription.closed) {
155 this.innerSubscription = undefined;
[all …]
|
| H A D | skipUntil.ts | 68 private innerSubscription?: Subscription;
74 this.innerSubscription = innerSubscriber;
75 const innerSubscription = innerSubscribe(notifier, innerSubscriber); constant
79 if (innerSubscription !== innerSubscriber) {
80 this.add(innerSubscription);
81 this.innerSubscription = innerSubscription;
93 if (this.innerSubscription) {
94 this.innerSubscription.unsubscribe();
|
| H A D | bufferToggle.ts | 169 const innerSubscription = subscribeToResult(this, closingNotifier, context as any); constant
171 if (!innerSubscription || innerSubscription.closed) {
174 (innerSubscription as any).context = context;
176 this.add(innerSubscription);
177 subscription.add(innerSubscription);
|
| H A D | audit.ts | 96 const innerSubscription = innerSubscribe(duration, new SimpleInnerSubscriber(this)); constant
97 if (!innerSubscription || innerSubscription.closed) {
100 this.add(this.throttled = innerSubscription);
|
| H A D | windowToggle.ts | 174 const innerSubscription = subscribeToResult(this, closingNotifier, context as any); constant
176 if (innerSubscription.closed) {
179 (<any>innerSubscription).context = context;
180 subscription.add(innerSubscription);
|
| H A D | catchError.ts | 138 const innerSubscription = innerSubscribe(result, innerSubscriber); constant
142 if (innerSubscription !== innerSubscriber) {
143 this.add(innerSubscription);
|
| H A D | mergeScan.ts | 107 const innerSubscription = innerSubscribe(ish, innerSubscriber); constant
111 if (innerSubscription !== innerSubscriber) {
112 destination.add(innerSubscription);
|
| /dports/misc/netron/node_modules/rxjs/src/internal/operators/ |
| H A D | switchMap.ts | 112 private innerSubscription: Subscription; property in SwitchMapSubscriber
132 const innerSubscription = this.innerSubscription; constant
133 if (innerSubscription) {
134 innerSubscription.unsubscribe();
139 this.innerSubscription = subscribeToResult(this, result, undefined, undefined, innerSubscriber);
143 if (this.innerSubscription !== innerSubscriber) {
144 destination.add(this.innerSubscription);
149 const {innerSubscription} = this; constant
150 if (!innerSubscription || innerSubscription.closed) {
157 this.innerSubscription = null;
[all …]
|
| H A D | skipUntil.ts | 70 private innerSubscription: Subscription; property in SkipUntilSubscriber
76 this.innerSubscription = innerSubscriber;
77 …const innerSubscription = subscribeToResult(this, notifier, undefined, undefined, innerSubscriber); constant
81 if (innerSubscription !== innerSubscriber) {
82 this.add(innerSubscription);
83 this.innerSubscription = innerSubscription;
97 if (this.innerSubscription) {
98 this.innerSubscription.unsubscribe();
|
| H A D | bufferToggle.ts | 171 const innerSubscription = subscribeToResult(this, closingNotifier, <any>context); constant
173 if (!innerSubscription || innerSubscription.closed) {
176 (<any> innerSubscription).context = context;
178 this.add(innerSubscription);
179 subscription.add(innerSubscription);
|
| H A D | audit.ts | 98 const innerSubscription = subscribeToResult(this, duration); constant
99 if (!innerSubscription || innerSubscription.closed) {
102 this.add(this.throttled = innerSubscription);
|
| H A D | windowToggle.ts | 174 const innerSubscription = subscribeToResult(this, closingNotifier, context as any); constant
176 if (innerSubscription.closed) {
179 (<any>innerSubscription).context = context;
180 subscription.add(innerSubscription);
|
| H A D | catchError.ts | 140 … const innerSubscription = subscribeToResult(this, result, undefined, undefined, innerSubscriber); constant
144 if (innerSubscription !== innerSubscriber) {
145 this.add(innerSubscription);
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/devtools-frontend/src/node_modules/rxjs/src/internal/operators/ |
| H A D | switchMap.ts | 112 private innerSubscription: Subscription; property in SwitchMapSubscriber
132 const innerSubscription = this.innerSubscription; constant
133 if (innerSubscription) {
134 innerSubscription.unsubscribe();
139 this.innerSubscription = subscribeToResult(this, result, undefined, undefined, innerSubscriber);
143 if (this.innerSubscription !== innerSubscriber) {
144 destination.add(this.innerSubscription);
149 const {innerSubscription} = this; constant
150 if (!innerSubscription || innerSubscription.closed) {
157 this.innerSubscription = null;
[all …]
|
| H A D | skipUntil.ts | 70 private innerSubscription: Subscription; property in SkipUntilSubscriber
76 this.innerSubscription = innerSubscriber;
77 …const innerSubscription = subscribeToResult(this, notifier, undefined, undefined, innerSubscriber); constant
81 if (innerSubscription !== innerSubscriber) {
82 this.add(innerSubscription);
83 this.innerSubscription = innerSubscription;
97 if (this.innerSubscription) {
98 this.innerSubscription.unsubscribe();
|
| H A D | bufferToggle.ts | 171 const innerSubscription = subscribeToResult(this, closingNotifier, <any>context); constant
173 if (!innerSubscription || innerSubscription.closed) {
176 (<any> innerSubscription).context = context;
178 this.add(innerSubscription);
179 subscription.add(innerSubscription);
|
| H A D | audit.ts | 98 const innerSubscription = subscribeToResult(this, duration); constant
99 if (!innerSubscription || innerSubscription.closed) {
102 this.add(this.throttled = innerSubscription);
|
| H A D | windowToggle.ts | 174 const innerSubscription = subscribeToResult(this, closingNotifier, context as any); constant
176 if (innerSubscription.closed) {
179 (<any>innerSubscription).context = context;
180 subscription.add(innerSubscription);
|
| H A D | catchError.ts | 140 … const innerSubscription = subscribeToResult(this, result, undefined, undefined, innerSubscriber); constant
144 if (innerSubscription !== innerSubscriber) {
145 this.add(innerSubscription);
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/devtools-frontend/src/node_modules/rxjs/src/internal/operators/ |
| H A D | switchMap.ts | 112 private innerSubscription: Subscription; property in SwitchMapSubscriber
132 const innerSubscription = this.innerSubscription; constant
133 if (innerSubscription) {
134 innerSubscription.unsubscribe();
139 this.innerSubscription = subscribeToResult(this, result, value, index, innerSubscriber);
143 const {innerSubscription} = this; constant
144 if (!innerSubscription || innerSubscription.closed) {
151 this.innerSubscription = null;
157 this.innerSubscription = null;
|
| H A D | bufferToggle.ts | 171 const innerSubscription = subscribeToResult(this, closingNotifier, <any>context); constant
173 if (!innerSubscription || innerSubscription.closed) {
176 (<any> innerSubscription).context = context;
178 this.add(innerSubscription);
179 subscription.add(innerSubscription);
|
| H A D | skipUntil.ts | 70 private innerSubscription: Subscription; property in SkipUntilSubscriber
76 this.innerSubscription = innerSubscriber;
90 if (this.innerSubscription) {
91 this.innerSubscription.unsubscribe();
|
| H A D | audit.ts | 98 const innerSubscription = subscribeToResult(this, duration); constant
99 if (!innerSubscription || innerSubscription.closed) {
102 this.add(this.throttled = innerSubscription);
|
| H A D | windowToggle.ts | 174 const innerSubscription = subscribeToResult(this, closingNotifier, context as any); constant
176 if (innerSubscription.closed) {
179 (<any>innerSubscription).context = context;
180 subscription.add(innerSubscription);
|
| /dports/lang/mono/mono-5.10.1.57/external/rx/Rx/NET/Source/System.Reactive.Linq/Reactive/Linq/Observable/ |
| H A D | SelectMany.cs | 160 var innerSubscription = new SingleAssignmentDisposable(); in OnNext()
161 _group.Add(innerSubscription); in OnNext()
162 … innerSubscription.Disposable = collection.SubscribeSafe(new Iter(this, value, innerSubscription)); in OnNext()
312 var innerSubscription = new SingleAssignmentDisposable(); in OnNext()
313 _group.Add(innerSubscription); in OnNext()
314 …innerSubscription.Disposable = collection.SubscribeSafe(new Iter(this, value, index, innerSubscrip… in OnNext()
1107 var innerSubscription = new SingleAssignmentDisposable(); in SubscribeInner()
1108 _group.Add(innerSubscription); in SubscribeInner()
1109 … innerSubscription.Disposable = inner.SubscribeSafe(new Iter(this, innerSubscription)); in SubscribeInner()
1297 _group.Add(innerSubscription); in SubscribeInner()
[all …]
|