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
/
throttle.js
diff --git
a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/throttle.js
b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/throttle.js
index fc073178ac53de32c5fd977257a5908862acd188..6b32790d8e59bb713611fb037c28d19f77725c00 100644
(file)
--- a/
.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/throttle.js
+++ b/
.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/throttle.js
@@
-1,11
+1,10
@@
-import { OuterSubscriber } from '../OuterSubscriber';
-import { subscribeToResult } from '../util/subscribeToResult';
+import { SimpleOuterSubscriber, innerSubscribe, SimpleInnerSubscriber } from '../innerSubscribe';
export const defaultThrottleConfig = {
leading: true,
trailing: false
};
export function throttle(durationSelector, config = defaultThrottleConfig) {
export const defaultThrottleConfig = {
leading: true,
trailing: false
};
export function throttle(durationSelector, config = defaultThrottleConfig) {
- return (source) => source.lift(new ThrottleOperator(durationSelector,
config.leading,
config.trailing));
+ return (source) => source.lift(new ThrottleOperator(durationSelector,
!!config.leading, !!
config.trailing));
}
class ThrottleOperator {
constructor(durationSelector, leading, trailing) {
}
class ThrottleOperator {
constructor(durationSelector, leading, trailing) {
@@
-17,7
+16,7
@@
class ThrottleOperator {
return source.subscribe(new ThrottleSubscriber(subscriber, this.durationSelector, this.leading, this.trailing));
}
}
return source.subscribe(new ThrottleSubscriber(subscriber, this.durationSelector, this.leading, this.trailing));
}
}
-class ThrottleSubscriber extends OuterSubscriber {
+class ThrottleSubscriber extends
Simple
OuterSubscriber {
constructor(destination, durationSelector, _leading, _trailing) {
super(destination);
this.destination = destination;
constructor(destination, durationSelector, _leading, _trailing) {
super(destination);
this.destination = destination;
@@
-45,12
+44,12
@@
class ThrottleSubscriber extends OuterSubscriber {
this.throttle(_sendValue);
}
this._hasValue = false;
this.throttle(_sendValue);
}
this._hasValue = false;
- this._sendValue =
null
;
+ this._sendValue =
undefined
;
}
throttle(value) {
const duration = this.tryDurationSelector(value);
if (!!duration) {
}
throttle(value) {
const duration = this.tryDurationSelector(value);
if (!!duration) {
- this.add(this._throttled =
subscribeToResult(this, duration
));
+ this.add(this._throttled =
innerSubscribe(duration, new SimpleInnerSubscriber(this)
));
}
}
tryDurationSelector(value) {
}
}
tryDurationSelector(value) {
@@
-67,12
+66,12
@@
class ThrottleSubscriber extends OuterSubscriber {
if (_throttled) {
_throttled.unsubscribe();
}
if (_throttled) {
_throttled.unsubscribe();
}
- this._throttled =
null
;
+ this._throttled =
undefined
;
if (_trailing) {
this.send();
}
}
if (_trailing) {
this.send();
}
}
- notifyNext(
outerValue, innerValue, outerIndex, innerIndex, innerSub
) {
+ notifyNext() {
this.throttlingDone();
}
notifyComplete() {
this.throttlingDone();
}
notifyComplete() {