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
/
throttle.ts
diff --git
a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/operators/throttle.ts
b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/operators/throttle.ts
index e855ff0a8a40336b0c83d98a32397dc42eb3593b..380e72e63b5bf571afb3d2e8ca4eb77352224216 100644
(file)
--- a/
.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/operators/throttle.ts
+++ b/
.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/operators/throttle.ts
@@
-3,11
+3,8
@@
import { Observable } from '../Observable';
import { Subscriber } from '../Subscriber';
import { Subscription } from '../Subscription';
import { Subscriber } from '../Subscriber';
import { Subscription } from '../Subscription';
-import { OuterSubscriber } from '../OuterSubscriber';
-import { InnerSubscriber } from '../InnerSubscriber';
-import { subscribeToResult } from '../util/subscribeToResult';
-
import { MonoTypeOperatorFunction, SubscribableOrPromise, TeardownLogic } from '../types';
import { MonoTypeOperatorFunction, SubscribableOrPromise, TeardownLogic } from '../types';
+import { SimpleOuterSubscriber, innerSubscribe, SimpleInnerSubscriber } from '../innerSubscribe';
export interface ThrottleConfig {
leading?: boolean;
export interface ThrottleConfig {
leading?: boolean;
@@
-67,7
+64,7
@@
export const defaultThrottleConfig: ThrottleConfig = {
*/
export function throttle<T>(durationSelector: (value: T) => SubscribableOrPromise<any>,
config: ThrottleConfig = defaultThrottleConfig): MonoTypeOperatorFunction<T> {
*/
export function throttle<T>(durationSelector: (value: T) => SubscribableOrPromise<any>,
config: ThrottleConfig = defaultThrottleConfig): MonoTypeOperatorFunction<T> {
- return (source: Observable<T>) => source.lift(new ThrottleOperator(durationSelector,
config.leading,
config.trailing));
+ return (source: Observable<T>) => source.lift(new ThrottleOperator(durationSelector,
!!config.leading, !!
config.trailing));
}
class ThrottleOperator<T> implements Operator<T, T> {
}
class ThrottleOperator<T> implements Operator<T, T> {
@@
-88,9
+85,9
@@
class ThrottleOperator<T> implements Operator<T, T> {
* @ignore
* @extends {Ignored}
*/
* @ignore
* @extends {Ignored}
*/
-class ThrottleSubscriber<T, R> extends OuterSubscriber<T, R> {
- private _throttled: Subscription;
- private _sendValue: T;
+class ThrottleSubscriber<T, R> extends
Simple
OuterSubscriber<T, R> {
+ private _throttled
?
: Subscription;
+ private _sendValue
?
: T;
private _hasValue = false;
constructor(protected destination: Subscriber<T>,
private _hasValue = false;
constructor(protected destination: Subscriber<T>,
@@
-117,20
+114,20
@@
class ThrottleSubscriber<T, R> extends OuterSubscriber<T, R> {
const { _hasValue, _sendValue } = this;
if (_hasValue) {
this.destination.next(_sendValue);
const { _hasValue, _sendValue } = this;
if (_hasValue) {
this.destination.next(_sendValue);
- this.throttle(_sendValue);
+ this.throttle(_sendValue
!
);
}
this._hasValue = false;
}
this._hasValue = false;
- this._sendValue =
null
;
+ this._sendValue =
undefined
;
}
private throttle(value: T): void {
const duration = this.tryDurationSelector(value);
if (!!duration) {
}
private throttle(value: T): void {
const duration = this.tryDurationSelector(value);
if (!!duration) {
- this.add(this._throttled =
subscribeToResult(this, duration
));
+ this.add(this._throttled =
innerSubscribe(duration, new SimpleInnerSubscriber(this)
));
}
}
}
}
- private tryDurationSelector(value: T): SubscribableOrPromise<any> {
+ private tryDurationSelector(value: T): SubscribableOrPromise<any>
| null
{
try {
return this.durationSelector(value);
} catch (err) {
try {
return this.durationSelector(value);
} catch (err) {
@@
-144,16
+141,14
@@
class ThrottleSubscriber<T, R> extends OuterSubscriber<T, R> {
if (_throttled) {
_throttled.unsubscribe();
}
if (_throttled) {
_throttled.unsubscribe();
}
- this._throttled =
null
;
+ this._throttled =
undefined
;
if (_trailing) {
this.send();
}
}
if (_trailing) {
this.send();
}
}
- notifyNext(outerValue: T, innerValue: R,
- outerIndex: number, innerIndex: number,
- innerSub: InnerSubscriber<T, R>): void {
+ notifyNext(): void {
this.throttlingDone();
}
this.throttlingDone();
}