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
/
_esm2015
/
internal
/
operators
/
skipUntil.js
diff --git
a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/skipUntil.js
b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/skipUntil.js
index 4909c5d8c022854386c968bf90f18f8d50904797..a0f54e3f32fba6849370abc1d0c39a7fb2368e62 100644
(file)
--- a/
.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/skipUntil.js
+++ b/
.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/skipUntil.js
@@
-1,6
+1,4
@@
-import { OuterSubscriber } from '../OuterSubscriber';
-import { InnerSubscriber } from '../InnerSubscriber';
-import { subscribeToResult } from '../util/subscribeToResult';
+import { SimpleOuterSubscriber, SimpleInnerSubscriber, innerSubscribe } from '../innerSubscribe';
export function skipUntil(notifier) {
return (source) => source.lift(new SkipUntilOperator(notifier));
}
export function skipUntil(notifier) {
return (source) => source.lift(new SkipUntilOperator(notifier));
}
@@
-12,14
+10,14
@@
class SkipUntilOperator {
return source.subscribe(new SkipUntilSubscriber(destination, this.notifier));
}
}
return source.subscribe(new SkipUntilSubscriber(destination, this.notifier));
}
}
-class SkipUntilSubscriber extends OuterSubscriber {
+class SkipUntilSubscriber extends
Simple
OuterSubscriber {
constructor(destination, notifier) {
super(destination);
this.hasValue = false;
constructor(destination, notifier) {
super(destination);
this.hasValue = false;
- 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);
if (innerSubscription !== innerSubscriber) {
this.add(innerSubscription);
this.innerSubscription = innerSubscription;
if (innerSubscription !== innerSubscriber) {
this.add(innerSubscription);
this.innerSubscription = innerSubscription;
@@
-30,7
+28,7
@@
class SkipUntilSubscriber extends OuterSubscriber {
super._next(value);
}
}
super._next(value);
}
}
- notifyNext(
outerValue, innerValue, outerIndex, innerIndex, innerSub
) {
+ notifyNext() {
this.hasValue = true;
if (this.innerSubscription) {
this.innerSubscription.unsubscribe();
this.hasValue = true;
if (this.innerSubscription) {
this.innerSubscription.unsubscribe();