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
/
debounce.js
diff --git
a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/debounce.js
b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/debounce.js
index e95c94eecdfe9ddeb5fff56136229963abcde5d4..4737d8f5f33f3127347747f56a79d0ba90c05b0b 100644
(file)
--- a/
.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/debounce.js
+++ b/
.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/debounce.js
@@
-1,5
+1,4
@@
-import { OuterSubscriber } from '../OuterSubscriber';
-import { subscribeToResult } from '../util/subscribeToResult';
+import { SimpleOuterSubscriber, innerSubscribe, SimpleInnerSubscriber } from '../innerSubscribe';
export function debounce(durationSelector) {
return (source) => source.lift(new DebounceOperator(durationSelector));
}
export function debounce(durationSelector) {
return (source) => source.lift(new DebounceOperator(durationSelector));
}
@@
-11,12
+10,11
@@
class DebounceOperator {
return source.subscribe(new DebounceSubscriber(subscriber, this.durationSelector));
}
}
return source.subscribe(new DebounceSubscriber(subscriber, this.durationSelector));
}
}
-class DebounceSubscriber extends OuterSubscriber {
+class DebounceSubscriber extends
Simple
OuterSubscriber {
constructor(destination, durationSelector) {
super(destination);
this.durationSelector = durationSelector;
this.hasValue = false;
constructor(destination, durationSelector) {
super(destination);
this.durationSelector = durationSelector;
this.hasValue = false;
- this.durationSubscription = null;
}
_next(value) {
try {
}
_next(value) {
try {
@@
-41,12
+39,12
@@
class DebounceSubscriber extends OuterSubscriber {
subscription.unsubscribe();
this.remove(subscription);
}
subscription.unsubscribe();
this.remove(subscription);
}
- subscription =
subscribeToResult(this, duration
);
+ subscription =
innerSubscribe(duration, new SimpleInnerSubscriber(this)
);
if (subscription && !subscription.closed) {
this.add(this.durationSubscription = subscription);
}
}
if (subscription && !subscription.closed) {
this.add(this.durationSubscription = subscription);
}
}
- notifyNext(
outerValue, innerValue, outerIndex, innerIndex, innerSub
) {
+ notifyNext() {
this.emitValue();
}
notifyComplete() {
this.emitValue();
}
notifyComplete() {
@@
-57,11
+55,11
@@
class DebounceSubscriber extends OuterSubscriber {
const value = this.value;
const subscription = this.durationSubscription;
if (subscription) {
const value = this.value;
const subscription = this.durationSubscription;
if (subscription) {
- this.durationSubscription =
null
;
+ this.durationSubscription =
undefined
;
subscription.unsubscribe();
this.remove(subscription);
}
subscription.unsubscribe();
this.remove(subscription);
}
- this.value =
null
;
+ this.value =
undefined
;
this.hasValue = false;
super._next(value);
}
this.hasValue = false;
super._next(value);
}