1 files changed, 0 insertions, 52 deletions
diff --git a/node_modules/rxjs/src/internal/testing/ColdObservable.ts b/node_modules/rxjs/src/internal/testing/ColdObservable.ts
deleted file mode 100644
index 40cbe49..0000000
--- a/node_modules/rxjs/src/internal/testing/ColdObservable.ts
+++ /dev/null
@@ -1,52 +0,0 @@
-import { Observable } from '../Observable';
-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 { Subscriber } from '../Subscriber';
-import { observeNotification } from '../Notification';
-
-export class ColdObservable<T> extends Observable<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(function (this: Observable<T>, subscriber: Subscriber<any>) {
-      const observable: ColdObservable<T> = this as any;
-      const index = observable.logSubscribedFrame();
-      const subscription = new Subscription();
-      subscription.add(
-        new Subscription(() => {
-          observable.logUnsubscribedFrame(index);
-        })
-      );
-      observable.scheduleMessages(subscriber);
-      return subscription;
-    });
-    this.scheduler = scheduler;
-  }
-
-  scheduleMessages(subscriber: Subscriber<any>) {
-    const messagesLength = this.messages.length;
-    for (let i = 0; i < messagesLength; i++) {
-      const message = this.messages[i];
-      subscriber.add(
-        this.scheduler.schedule(
-          (state) => {
-            const { message: { notification }, subscriber: destination } = state!;
-            observeNotification(notification, destination);
-          },
-          message.frame,
-          { message, subscriber }
-        )
-      );
-    }
-  }
-}
-applyMixins(ColdObservable, [SubscriptionLoggable]);