projects
/
dotfiles
/
.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Giant blob of minor changes
[dotfiles/.git]
/
.config
/
coc
/
extensions
/
node_modules
/
coc-prettier
/
node_modules
/
rxjs
/
src
/
internal
/
operators
/
skipUntil.ts
diff --git
a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/operators/skipUntil.ts
b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/operators/skipUntil.ts
index 8310adca587653d2176259b116afd94bebf89f27..66e25318423288fcb2ad52e6d691a4447cac051c 100644
(file)
--- a/
.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/operators/skipUntil.ts
+++ b/
.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/operators/skipUntil.ts
@@
-1,11
+1,9
@@
import { Operator } from '../Operator';
import { Subscriber } from '../Subscriber';
import { Observable } from '../Observable';
import { Operator } from '../Operator';
import { Subscriber } from '../Subscriber';
import { Observable } from '../Observable';
-import { OuterSubscriber } from '../OuterSubscriber';
-import { InnerSubscriber } from '../InnerSubscriber';
-import { subscribeToResult } from '../util/subscribeToResult';
import { MonoTypeOperatorFunction, TeardownLogic, ObservableInput } from '../types';
import { Subscription } from '../Subscription';
import { MonoTypeOperatorFunction, TeardownLogic, ObservableInput } from '../types';
import { Subscription } from '../Subscription';
+import { SimpleOuterSubscriber, SimpleInnerSubscriber, innerSubscribe } from '../innerSubscribe';
/**
* Returns an Observable that skips items emitted by the source Observable until a second Observable emits an item.
/**
* Returns an Observable that skips items emitted by the source Observable until a second Observable emits an item.
@@
-64,17
+62,17
@@
class SkipUntilOperator<T> implements Operator<T, T> {
* @ignore
* @extends {Ignored}
*/
* @ignore
* @extends {Ignored}
*/
-class SkipUntilSubscriber<T, R> extends OuterSubscriber<T, R> {
+class SkipUntilSubscriber<T, R> extends
Simple
OuterSubscriber<T, R> {
private hasValue: boolean = false;
private hasValue: boolean = false;
- private innerSubscription: Subscription;
+ private innerSubscription
?
: Subscription;
constructor(destination: Subscriber<R>, notifier: ObservableInput<any>) {
super(destination);
constructor(destination: Subscriber<R>, notifier: ObservableInput<any>) {
super(destination);
- const innerSubscriber = new
InnerSubscriber(this, undefined, undefined
);
+ const innerSubscriber = new
SimpleInnerSubscriber(this
);
this.add(innerSubscriber);
this.innerSubscription = innerSubscriber;
this.add(innerSubscriber);
this.innerSubscription = innerSubscriber;
- const innerSubscription =
subscribeToResult(this, notifier, undefined, undefined
, innerSubscriber);
+ const innerSubscription =
innerSubscribe(notifier
, innerSubscriber);
// The returned subscription will usually be the subscriber that was
// passed. However, interop subscribers will be wrapped and for
// unsubscriptions to chain correctly, the wrapper needs to be added, too.
// The returned subscription will usually be the subscriber that was
// passed. However, interop subscribers will be wrapped and for
// unsubscriptions to chain correctly, the wrapper needs to be added, too.
@@
-90,9
+88,7
@@
class SkipUntilSubscriber<T, R> extends OuterSubscriber<T, R> {
}
}
}
}
- notifyNext(outerValue: T, innerValue: R,
- outerIndex: number, innerIndex: number,
- innerSub: InnerSubscriber<T, R>): void {
+ notifyNext(): void {
this.hasValue = true;
if (this.innerSubscription) {
this.innerSubscription.unsubscribe();
this.hasValue = true;
if (this.innerSubscription) {
this.innerSubscription.unsubscribe();