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 { OuterSubscriber } from '../OuterSubscriber';
-import { InnerSubscriber } from '../InnerSubscriber';
-import { subscribeToResult } from '../util/subscribeToResult';
-
 import { MonoTypeOperatorFunction, SubscribableOrPromise, TeardownLogic } from '../types';
+import { SimpleOuterSubscriber, innerSubscribe, SimpleInnerSubscriber } from '../innerSubscribe';
 
 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> {
-  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> {
@@ -88,9 +85,9 @@ class ThrottleOperator<T> implements Operator<T, T> {
  * @ignore
  * @extends {Ignored}
  */
-class ThrottleSubscriber<T, R> extends OuterSubscriber<T, R> {
-  private _throttled: Subscription;
-  private _sendValue: T;
+class ThrottleSubscriber<T, R> extends SimpleOuterSubscriber<T, R> {
+  private _throttled?: Subscription;
+  private _sendValue?: 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);
-      this.throttle(_sendValue);
+      this.throttle(_sendValue!);
     }
     this._hasValue = false;
-    this._sendValue = null;
+    this._sendValue = undefined;
   }
 
   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) {
@@ -144,16 +141,14 @@ class ThrottleSubscriber<T, R> extends OuterSubscriber<T, R> {
     if (_throttled) {
       _throttled.unsubscribe();
     }
-    this._throttled = null;
+    this._throttled = undefined;
 
     if (_trailing) {
       this.send();
     }
   }
 
-  notifyNext(outerValue: T, innerValue: R,
-             outerIndex: number, innerIndex: number,
-             innerSub: InnerSubscriber<T, R>): void {
+  notifyNext(): void {
     this.throttlingDone();
   }