1 files changed, 52 insertions, 0 deletions
diff --git a/node_modules/rxjs/src/internal/testing/ColdObservable.ts b/node_modules/rxjs/src/internal/testing/ColdObservable.ts
new file mode 100644
index 0000000..40cbe49
--- /dev/null
+++ b/node_modules/rxjs/src/internal/testing/ColdObservable.ts
@@ -0,0 +1,52 @@
+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]);