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
/
exhaust.js
diff --git
a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/exhaust.js
b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/exhaust.js
index ae4a72c2e2b45f16ec32279bdf5541709d9ae75a..fd0fb0857acf3825a7d0e0540bdd666fff11b284 100644
(file)
--- a/
.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/exhaust.js
+++ b/
.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/exhaust.js
@@
-1,5
+1,4
@@
-import { OuterSubscriber } from '../OuterSubscriber';
-import { subscribeToResult } from '../util/subscribeToResult';
+import { SimpleOuterSubscriber, innerSubscribe, SimpleInnerSubscriber } from '../innerSubscribe';
export function exhaust() {
return (source) => source.lift(new SwitchFirstOperator());
}
export function exhaust() {
return (source) => source.lift(new SwitchFirstOperator());
}
@@
-8,7
+7,7
@@
class SwitchFirstOperator {
return source.subscribe(new SwitchFirstSubscriber(subscriber));
}
}
return source.subscribe(new SwitchFirstSubscriber(subscriber));
}
}
-class SwitchFirstSubscriber extends OuterSubscriber {
+class SwitchFirstSubscriber extends
Simple
OuterSubscriber {
constructor(destination) {
super(destination);
this.hasCompleted = false;
constructor(destination) {
super(destination);
this.hasCompleted = false;
@@
-17,7
+16,7
@@
class SwitchFirstSubscriber extends OuterSubscriber {
_next(value) {
if (!this.hasSubscription) {
this.hasSubscription = true;
_next(value) {
if (!this.hasSubscription) {
this.hasSubscription = true;
- this.add(
subscribeToResult(this, value
));
+ this.add(
innerSubscribe(value, new SimpleInnerSubscriber(this)
));
}
}
_complete() {
}
}
_complete() {
@@
-26,8
+25,7
@@
class SwitchFirstSubscriber extends OuterSubscriber {
this.destination.complete();
}
}
this.destination.complete();
}
}
- notifyComplete(innerSub) {
- this.remove(innerSub);
+ notifyComplete() {
this.hasSubscription = false;
if (this.hasCompleted) {
this.destination.complete();
this.hasSubscription = false;
if (this.hasCompleted) {
this.destination.complete();