some deletions

[dotfiles/.git] / .config / coc / extensions / node_modules / coc-prettier / node_modules / rxjs / _esm2015 / internal / operators / sampleTime.js

diff --git a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/sampleTime.js b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/sampleTime.js
deleted file mode 100644 (file)
index a3b08c2..0000000
--- a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/sampleTime.js
+++ /dev/null
@@ -1,39 +0,0 @@
-import { Subscriber } from '../Subscriber';
-import { async } from '../scheduler/async';
-export function sampleTime(period, scheduler = async) {
-    return (source) => source.lift(new SampleTimeOperator(period, scheduler));
-}
-class SampleTimeOperator {
-    constructor(period, scheduler) {
-        this.period = period;
-        this.scheduler = scheduler;
-    }
-    call(subscriber, source) {
-        return source.subscribe(new SampleTimeSubscriber(subscriber, this.period, this.scheduler));
-    }
-}
-class SampleTimeSubscriber extends Subscriber {
-    constructor(destination, period, scheduler) {
-        super(destination);
-        this.period = period;
-        this.scheduler = scheduler;
-        this.hasValue = false;
-        this.add(scheduler.schedule(dispatchNotification, period, { subscriber: this, period }));
-    }
-    _next(value) {
-        this.lastValue = value;
-        this.hasValue = true;
-    }
-    notifyNext() {
-        if (this.hasValue) {
-            this.hasValue = false;
-            this.destination.next(this.lastValue);
-        }
-    }
-}
-function dispatchNotification(state) {
-    let { subscriber, period } = state;
-    subscriber.notifyNext();
-    this.schedule(state, period);
-}
-//# sourceMappingURL=sampleTime.js.map
\ No newline at end of file