.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/throttle.js

   1 import { SimpleOuterSubscriber, innerSubscribe, SimpleInnerSubscriber } from '../innerSubscribe';
   2 export const defaultThrottleConfig = {
   3     leading: true,
   4     trailing: false
   5 };
   6 export function throttle(durationSelector, config = defaultThrottleConfig) {
   7     return (source) => source.lift(new ThrottleOperator(durationSelector, !!config.leading, !!config.trailing));
   8 }
   9 class ThrottleOperator {
  10     constructor(durationSelector, leading, trailing) {
  11         this.durationSelector = durationSelector;
  12         this.leading = leading;
  13         this.trailing = trailing;
  14     }
  15     call(subscriber, source) {
  16         return source.subscribe(new ThrottleSubscriber(subscriber, this.durationSelector, this.leading, this.trailing));
  17     }
  18 }
  19 class ThrottleSubscriber extends SimpleOuterSubscriber {
  20     constructor(destination, durationSelector, _leading, _trailing) {
  21         super(destination);
  22         this.destination = destination;
  23         this.durationSelector = durationSelector;
  24         this._leading = _leading;
  25         this._trailing = _trailing;
  26         this._hasValue = false;
  27     }
  28     _next(value) {
  29         this._hasValue = true;
  30         this._sendValue = value;
  31         if (!this._throttled) {
  32             if (this._leading) {
  33                 this.send();
  34             }
  35             else {
  36                 this.throttle(value);
  37             }
  38         }
  39     }
  40     send() {
  41         const { _hasValue, _sendValue } = this;
  42         if (_hasValue) {
  43             this.destination.next(_sendValue);
  44             this.throttle(_sendValue);
  45         }
  46         this._hasValue = false;
  47         this._sendValue = undefined;
  48     }
  49     throttle(value) {
  50         const duration = this.tryDurationSelector(value);
  51         if (!!duration) {
  52             this.add(this._throttled = innerSubscribe(duration, new SimpleInnerSubscriber(this)));
  53         }
  54     }
  55     tryDurationSelector(value) {
  56         try {
  57             return this.durationSelector(value);
  58         }
  59         catch (err) {
  60             this.destination.error(err);
  61             return null;
  62         }
  63     }
  64     throttlingDone() {
  65         const { _throttled, _trailing } = this;
  66         if (_throttled) {
  67             _throttled.unsubscribe();
  68         }
  69         this._throttled = undefined;
  70         if (_trailing) {
  71             this.send();
  72         }
  73     }
  74     notifyNext() {
  75         this.throttlingDone();
  76     }
  77     notifyComplete() {
  78         this.throttlingDone();
  79     }
  80 }
  81 //# sourceMappingURL=throttle.js.map