Home
last modified time | relevance | path

Searched refs:innerSubscriber (Results 1 – 25 of 47) sorted by relevance

12

/dports/misc/netron/node_modules/rxjs/src/internal/util/
H A DsubscribeToResult.ts13 innerSubscriber: InnerSubscriber<T, R>
28 innerSubscriber: Subscriber<R> = new InnerSubscriber(outerSubscriber, outerValue, outerIndex)
30 if (innerSubscriber.closed) {
34 return result.subscribe(innerSubscriber);
36 return subscribeTo(result)(innerSubscriber) as Subscription;
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/devtools-frontend/src/node_modules/rxjs/src/internal/util/
H A DsubscribeToResult.ts13 innerSubscriber: InnerSubscriber<T, R>
28 innerSubscriber: Subscriber<R> = new InnerSubscriber(outerSubscriber, outerValue, outerIndex)
30 if (innerSubscriber.closed) {
34 return result.subscribe(innerSubscriber);
36 return subscribeTo(result)(innerSubscriber) as Subscription;
/dports/textproc/write-good/write-good-1.0.8/node_modules/rxjs/src/internal/util/
H A DsubscribeToResult.ts13 innerSubscriber: InnerSubscriber<T, R>
28 innerSubscriber: Subscriber<R> = new InnerSubscriber(outerSubscriber, outerValue, outerIndex)
30 if (innerSubscriber.closed) {
34 return result.subscribe(innerSubscriber);
36 return subscribeTo(result)(innerSubscriber) as Subscription;
/dports/textproc/write-good/write-good-1.0.8/node_modules/rxjs/src/internal/operators/
H A DskipUntil.ts72 const innerSubscriber = new SimpleInnerSubscriber(this); constant
73 this.add(innerSubscriber);
74 this.innerSubscription = innerSubscriber;
75 const innerSubscription = innerSubscribe(notifier, innerSubscriber);
79 if (innerSubscription !== innerSubscriber) {
H A DcatchError.ts136 const innerSubscriber = new SimpleInnerSubscriber(this); constant
137 this.add(innerSubscriber);
138 const innerSubscription = innerSubscribe(result, innerSubscriber);
142 if (innerSubscription !== innerSubscriber) {
H A DmergeScan.ts104 const innerSubscriber = new SimpleInnerSubscriber(this); constant
106 destination.add(innerSubscriber);
107 const innerSubscription = innerSubscribe(ish, innerSubscriber);
111 if (innerSubscription !== innerSubscriber) {
H A DexhaustMap.ts123 const innerSubscriber = new SimpleInnerSubscriber(this); constant
125 destination.add(innerSubscriber);
126 const innerSubscription = innerSubscribe(result, innerSubscriber);
130 if (innerSubscription !== innerSubscriber) {
H A DswitchMap.ts134 const innerSubscriber = new SimpleInnerSubscriber(this); constant
136 destination.add(innerSubscriber);
137 this.innerSubscription = innerSubscribe(result, innerSubscriber);
141 if (this.innerSubscription !== innerSubscriber) {
H A DmergeMap.ts141 const innerSubscriber = new SimpleInnerSubscriber(this); constant
143 destination.add(innerSubscriber);
144 const innerSubscription = innerSubscribe(ish, innerSubscriber);
148 if (innerSubscription !== innerSubscriber) {
/dports/misc/netron/node_modules/rxjs/src/internal/operators/
H A DskipUntil.ts74 const innerSubscriber = new InnerSubscriber(this, undefined, undefined); constant
75 this.add(innerSubscriber);
76 this.innerSubscription = innerSubscriber;
77 …const innerSubscription = subscribeToResult(this, notifier, undefined, undefined, innerSubscriber);
81 if (innerSubscription !== innerSubscriber) {
H A DcatchError.ts138 const innerSubscriber = new InnerSubscriber(this, undefined, undefined); constant
139 this.add(innerSubscriber);
140 … const innerSubscription = subscribeToResult(this, result, undefined, undefined, innerSubscriber);
144 if (innerSubscription !== innerSubscriber) {
H A DmergeScan.ts106 const innerSubscriber = new InnerSubscriber(this, value, index); constant
108 destination.add(innerSubscriber);
109 …onst innerSubscription = subscribeToResult<T, R>(this, ish, undefined, undefined, innerSubscriber);
113 if (innerSubscription !== innerSubscriber) {
H A DexhaustMap.ts125 const innerSubscriber = new InnerSubscriber(this, value, index); constant
127 destination.add(innerSubscriber);
128 …t innerSubscription = subscribeToResult<T, R>(this, result, undefined, undefined, innerSubscriber);
132 if (innerSubscription !== innerSubscriber) {
H A DswitchMap.ts136 const innerSubscriber = new InnerSubscriber(this, value, index); constant
138 destination.add(innerSubscriber);
139 this.innerSubscription = subscribeToResult(this, result, undefined, undefined, innerSubscriber);
143 if (this.innerSubscription !== innerSubscriber) {
H A DmergeMap.ts145 const innerSubscriber = new InnerSubscriber(this, value, index); constant
147 destination.add(innerSubscriber);
148 …onst innerSubscription = subscribeToResult<T, R>(this, ish, undefined, undefined, innerSubscriber);
152 if (innerSubscription !== innerSubscriber) {
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/devtools-frontend/src/node_modules/rxjs/src/internal/operators/
H A DskipUntil.ts74 const innerSubscriber = new InnerSubscriber(this, undefined, undefined); constant
75 this.add(innerSubscriber);
76 this.innerSubscription = innerSubscriber;
77 …const innerSubscription = subscribeToResult(this, notifier, undefined, undefined, innerSubscriber);
81 if (innerSubscription !== innerSubscriber) {
H A DcatchError.ts138 const innerSubscriber = new InnerSubscriber(this, undefined, undefined); constant
139 this.add(innerSubscriber);
140 … const innerSubscription = subscribeToResult(this, result, undefined, undefined, innerSubscriber);
144 if (innerSubscription !== innerSubscriber) {
H A DmergeScan.ts106 const innerSubscriber = new InnerSubscriber(this, value, index); constant
108 destination.add(innerSubscriber);
109 …onst innerSubscription = subscribeToResult<T, R>(this, ish, undefined, undefined, innerSubscriber);
113 if (innerSubscription !== innerSubscriber) {
H A DexhaustMap.ts125 const innerSubscriber = new InnerSubscriber(this, value, index); constant
127 destination.add(innerSubscriber);
128 …t innerSubscription = subscribeToResult<T, R>(this, result, undefined, undefined, innerSubscriber);
132 if (innerSubscription !== innerSubscriber) {
H A DswitchMap.ts136 const innerSubscriber = new InnerSubscriber(this, value, index); constant
138 destination.add(innerSubscriber);
139 this.innerSubscription = subscribeToResult(this, result, undefined, undefined, innerSubscriber);
143 if (this.innerSubscription !== innerSubscriber) {
H A DmergeMap.ts145 const innerSubscriber = new InnerSubscriber(this, value, index); constant
147 destination.add(innerSubscriber);
148 …onst innerSubscription = subscribeToResult<T, R>(this, ish, undefined, undefined, innerSubscriber);
152 if (innerSubscription !== innerSubscriber) {
/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 DskipUntil.ts74 const innerSubscriber = new InnerSubscriber(this, undefined, undefined); constant
75 this.add(innerSubscriber);
76 this.innerSubscription = innerSubscriber;
77 subscribeToResult(this, notifier, undefined, undefined, innerSubscriber);
H A DcatchError.ts138 const innerSubscriber = new InnerSubscriber(this, undefined, undefined); constant
139 this.add(innerSubscriber);
140 subscribeToResult(this, result, undefined, undefined, innerSubscriber);
H A DmergeScan.ts106 const innerSubscriber = new InnerSubscriber(this, undefined, undefined); constant
108 destination.add(innerSubscriber);
109 subscribeToResult<T, R>(this, ish, value, index, innerSubscriber);
/dports/textproc/write-good/write-good-1.0.8/node_modules/rxjs/src/internal/
H A DinnerSubscribe.ts106 export function innerSubscribe(result: any, innerSubscriber: Subscriber<any>): Subscription | undef…
107 if (innerSubscriber.closed) {
111 return result.subscribe(innerSubscriber);
113 return subscribeTo(result)(innerSubscriber) as Subscription;

12