some deletions

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

diff --git a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/testing/HotObservable.js b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/testing/HotObservable.js
deleted file mode 100644 (file)
index e2ac763..0000000
--- a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/testing/HotObservable.js
+++ /dev/null
@@ -1,34 +0,0 @@
-import { Subject } from '../Subject';
-import { Subscription } from '../Subscription';
-import { SubscriptionLoggable } from './SubscriptionLoggable';
-import { applyMixins } from '../util/applyMixins';
-export class HotObservable extends Subject {
-    constructor(messages, scheduler) {
-        super();
-        this.messages = messages;
-        this.subscriptions = [];
-        this.scheduler = scheduler;
-    }
-    _subscribe(subscriber) {
-        const subject = this;
-        const index = subject.logSubscribedFrame();
-        const subscription = new Subscription();
-        subscription.add(new Subscription(() => {
-            subject.logUnsubscribedFrame(index);
-        }));
-        subscription.add(super._subscribe(subscriber));
-        return subscription;
-    }
-    setup() {
-        const subject = this;
-        const messagesLength = subject.messages.length;
-        for (var i = 0; i < messagesLength; i++) {
-            (() => {
-                var message = subject.messages[i];
-                subject.scheduler.schedule(() => { message.notification.observe(subject); }, message.frame);
-            })();
-        }
-    }
-}
-applyMixins(HotObservable, [SubscriptionLoggable]);
-//# sourceMappingURL=HotObservable.js.map
\ No newline at end of file