From e4fa1e69e7ebfb627c7198fd1a9881e9327ec4d4 Mon Sep 17 00:00:00 2001 From: Pinapelz Date: Sat, 28 Jun 2025 17:26:46 -0700 Subject: initial commit: scaffolding --- .../dist/esm/internal/testing/ColdObservable.js | 34 ++++++++++++++++++++++ 1 file changed, 34 insertions(+) create mode 100644 node_modules/rxjs/dist/esm/internal/testing/ColdObservable.js (limited to 'node_modules/rxjs/dist/esm/internal/testing/ColdObservable.js') diff --git a/node_modules/rxjs/dist/esm/internal/testing/ColdObservable.js b/node_modules/rxjs/dist/esm/internal/testing/ColdObservable.js new file mode 100644 index 0000000..0733e6e --- /dev/null +++ b/node_modules/rxjs/dist/esm/internal/testing/ColdObservable.js @@ -0,0 +1,34 @@ +import { Observable } from '../Observable'; +import { Subscription } from '../Subscription'; +import { SubscriptionLoggable } from './SubscriptionLoggable'; +import { applyMixins } from '../util/applyMixins'; +import { observeNotification } from '../Notification'; +export class ColdObservable extends Observable { + constructor(messages, scheduler) { + super(function (subscriber) { + const observable = this; + const index = observable.logSubscribedFrame(); + const subscription = new Subscription(); + subscription.add(new Subscription(() => { + observable.logUnsubscribedFrame(index); + })); + observable.scheduleMessages(subscriber); + return subscription; + }); + this.messages = messages; + this.subscriptions = []; + this.scheduler = scheduler; + } + scheduleMessages(subscriber) { + 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]); +//# sourceMappingURL=ColdObservable.js.map \ No newline at end of file -- cgit v1.2.3