remove dev node_modules (oops)

1 files changed, 0 insertions, 53 deletions

diff --git a/node_modules/rxjs/src/internal/testing/HotObservable.ts b/node_modules/rxjs/src/internal/testing/HotObservable.ts
deleted file mode 100644
index c151480..0000000
--- a/node_modules/rxjs/src/internal/testing/HotObservable.ts
+++ /dev/null
@@ -1,53 +0,0 @@
-import { Subject } from '../Subject';
-import { Subscriber } from '../Subscriber';
-import { Subscription } from '../Subscription';
-import { Scheduler } from '../Scheduler';
-import { TestMessage } from './TestMessage';
-import { SubscriptionLog } from './SubscriptionLog';
-import { SubscriptionLoggable } from './SubscriptionLoggable';
-import { applyMixins } from '../util/applyMixins';
-import { observeNotification } from '../Notification';
-
-export class HotObservable<T> extends Subject<T> implements SubscriptionLoggable {
-  public subscriptions: SubscriptionLog[] = [];
-  scheduler: Scheduler;
-  // @ts-ignore: Property has no initializer and is not definitely assigned
-  logSubscribedFrame: () => number;
-  // @ts-ignore: Property has no initializer and is not definitely assigned
-  logUnsubscribedFrame: (index: number) => void;
-
-  constructor(public messages: TestMessage[], scheduler: Scheduler) {
-    super();
-    this.scheduler = scheduler;
-  }
-
-  /** @internal */
-  protected _subscribe(subscriber: Subscriber<any>): Subscription {
-    const subject: HotObservable<T> = 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;
-    /* tslint:disable:no-var-keyword */
-    for (let i = 0; i < messagesLength; i++) {
-      (() => {
-        const { notification, frame } = subject.messages[i];
-        /* tslint:enable */
-        subject.scheduler.schedule(() => {
-          observeNotification(notification, subject);
-        }, frame);
-      })();
-    }
-  }
-}
-applyMixins(HotObservable, [SubscriptionLoggable]);