From d55b767039605256c736166a942a9138e3eacfd7 Mon Sep 17 00:00:00 2001 From: Pinapelz Date: Sun, 29 Jun 2025 11:49:28 -0700 Subject: remove dev node_modules (oops) --- .../dist/cjs/internal/testing/TestScheduler.js | 618 --------------------- 1 file changed, 618 deletions(-) delete mode 100644 node_modules/rxjs/dist/cjs/internal/testing/TestScheduler.js (limited to 'node_modules/rxjs/dist/cjs/internal/testing/TestScheduler.js') diff --git a/node_modules/rxjs/dist/cjs/internal/testing/TestScheduler.js b/node_modules/rxjs/dist/cjs/internal/testing/TestScheduler.js deleted file mode 100644 index a7a4924..0000000 --- a/node_modules/rxjs/dist/cjs/internal/testing/TestScheduler.js +++ /dev/null @@ -1,618 +0,0 @@ -"use strict"; -var __extends = (this && this.__extends) || (function () { - var extendStatics = function (d, b) { - extendStatics = Object.setPrototypeOf || - ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) || - function (d, b) { for (var p in b) if (Object.prototype.hasOwnProperty.call(b, p)) d[p] = b[p]; }; - return extendStatics(d, b); - }; - return function (d, b) { - if (typeof b !== "function" && b !== null) - throw new TypeError("Class extends value " + String(b) + " is not a constructor or null"); - extendStatics(d, b); - function __() { this.constructor = d; } - d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __()); - }; -})(); -var __read = (this && this.__read) || function (o, n) { - var m = typeof Symbol === "function" && o[Symbol.iterator]; - if (!m) return o; - var i = m.call(o), r, ar = [], e; - try { - while ((n === void 0 || n-- > 0) && !(r = i.next()).done) ar.push(r.value); - } - catch (error) { e = { error: error }; } - finally { - try { - if (r && !r.done && (m = i["return"])) m.call(i); - } - finally { if (e) throw e.error; } - } - return ar; -}; -var __spreadArray = (this && this.__spreadArray) || function (to, from) { - for (var i = 0, il = from.length, j = to.length; i < il; i++, j++) - to[j] = from[i]; - return to; -}; -var __values = (this && this.__values) || function(o) { - var s = typeof Symbol === "function" && Symbol.iterator, m = s && o[s], i = 0; - if (m) return m.call(o); - if (o && typeof o.length === "number") return { - next: function () { - if (o && i >= o.length) o = void 0; - return { value: o && o[i++], done: !o }; - } - }; - throw new TypeError(s ? "Object is not iterable." : "Symbol.iterator is not defined."); -}; -Object.defineProperty(exports, "__esModule", { value: true }); -exports.TestScheduler = void 0; -var Observable_1 = require("../Observable"); -var ColdObservable_1 = require("./ColdObservable"); -var HotObservable_1 = require("./HotObservable"); -var SubscriptionLog_1 = require("./SubscriptionLog"); -var VirtualTimeScheduler_1 = require("../scheduler/VirtualTimeScheduler"); -var NotificationFactories_1 = require("../NotificationFactories"); -var dateTimestampProvider_1 = require("../scheduler/dateTimestampProvider"); -var performanceTimestampProvider_1 = require("../scheduler/performanceTimestampProvider"); -var animationFrameProvider_1 = require("../scheduler/animationFrameProvider"); -var immediateProvider_1 = require("../scheduler/immediateProvider"); -var intervalProvider_1 = require("../scheduler/intervalProvider"); -var timeoutProvider_1 = require("../scheduler/timeoutProvider"); -var defaultMaxFrame = 750; -var TestScheduler = (function (_super) { - __extends(TestScheduler, _super); - function TestScheduler(assertDeepEqual) { - var _this = _super.call(this, VirtualTimeScheduler_1.VirtualAction, defaultMaxFrame) || this; - _this.assertDeepEqual = assertDeepEqual; - _this.hotObservables = []; - _this.coldObservables = []; - _this.flushTests = []; - _this.runMode = false; - return _this; - } - TestScheduler.prototype.createTime = function (marbles) { - var indexOf = this.runMode ? marbles.trim().indexOf('|') : marbles.indexOf('|'); - if (indexOf === -1) { - throw new Error('marble diagram for time should have a completion marker "|"'); - } - return indexOf * TestScheduler.frameTimeFactor; - }; - TestScheduler.prototype.createColdObservable = function (marbles, values, error) { - if (marbles.indexOf('^') !== -1) { - throw new Error('cold observable cannot have subscription offset "^"'); - } - if (marbles.indexOf('!') !== -1) { - throw new Error('cold observable cannot have unsubscription marker "!"'); - } - var messages = TestScheduler.parseMarbles(marbles, values, error, undefined, this.runMode); - var cold = new ColdObservable_1.ColdObservable(messages, this); - this.coldObservables.push(cold); - return cold; - }; - TestScheduler.prototype.createHotObservable = function (marbles, values, error) { - if (marbles.indexOf('!') !== -1) { - throw new Error('hot observable cannot have unsubscription marker "!"'); - } - var messages = TestScheduler.parseMarbles(marbles, values, error, undefined, this.runMode); - var subject = new HotObservable_1.HotObservable(messages, this); - this.hotObservables.push(subject); - return subject; - }; - TestScheduler.prototype.materializeInnerObservable = function (observable, outerFrame) { - var _this = this; - var messages = []; - observable.subscribe({ - next: function (value) { - messages.push({ frame: _this.frame - outerFrame, notification: NotificationFactories_1.nextNotification(value) }); - }, - error: function (error) { - messages.push({ frame: _this.frame - outerFrame, notification: NotificationFactories_1.errorNotification(error) }); - }, - complete: function () { - messages.push({ frame: _this.frame - outerFrame, notification: NotificationFactories_1.COMPLETE_NOTIFICATION }); - }, - }); - return messages; - }; - TestScheduler.prototype.expectObservable = function (observable, subscriptionMarbles) { - var _this = this; - if (subscriptionMarbles === void 0) { subscriptionMarbles = null; } - var actual = []; - var flushTest = { actual: actual, ready: false }; - var subscriptionParsed = TestScheduler.parseMarblesAsSubscriptions(subscriptionMarbles, this.runMode); - var subscriptionFrame = subscriptionParsed.subscribedFrame === Infinity ? 0 : subscriptionParsed.subscribedFrame; - var unsubscriptionFrame = subscriptionParsed.unsubscribedFrame; - var subscription; - this.schedule(function () { - subscription = observable.subscribe({ - next: function (x) { - var value = x instanceof Observable_1.Observable ? _this.materializeInnerObservable(x, _this.frame) : x; - actual.push({ frame: _this.frame, notification: NotificationFactories_1.nextNotification(value) }); - }, - error: function (error) { - actual.push({ frame: _this.frame, notification: NotificationFactories_1.errorNotification(error) }); - }, - complete: function () { - actual.push({ frame: _this.frame, notification: NotificationFactories_1.COMPLETE_NOTIFICATION }); - }, - }); - }, subscriptionFrame); - if (unsubscriptionFrame !== Infinity) { - this.schedule(function () { return subscription.unsubscribe(); }, unsubscriptionFrame); - } - this.flushTests.push(flushTest); - var runMode = this.runMode; - return { - toBe: function (marbles, values, errorValue) { - flushTest.ready = true; - flushTest.expected = TestScheduler.parseMarbles(marbles, values, errorValue, true, runMode); - }, - toEqual: function (other) { - flushTest.ready = true; - flushTest.expected = []; - _this.schedule(function () { - subscription = other.subscribe({ - next: function (x) { - var value = x instanceof Observable_1.Observable ? _this.materializeInnerObservable(x, _this.frame) : x; - flushTest.expected.push({ frame: _this.frame, notification: NotificationFactories_1.nextNotification(value) }); - }, - error: function (error) { - flushTest.expected.push({ frame: _this.frame, notification: NotificationFactories_1.errorNotification(error) }); - }, - complete: function () { - flushTest.expected.push({ frame: _this.frame, notification: NotificationFactories_1.COMPLETE_NOTIFICATION }); - }, - }); - }, subscriptionFrame); - }, - }; - }; - TestScheduler.prototype.expectSubscriptions = function (actualSubscriptionLogs) { - var flushTest = { actual: actualSubscriptionLogs, ready: false }; - this.flushTests.push(flushTest); - var runMode = this.runMode; - return { - toBe: function (marblesOrMarblesArray) { - var marblesArray = typeof marblesOrMarblesArray === 'string' ? [marblesOrMarblesArray] : marblesOrMarblesArray; - flushTest.ready = true; - flushTest.expected = marblesArray - .map(function (marbles) { return TestScheduler.parseMarblesAsSubscriptions(marbles, runMode); }) - .filter(function (marbles) { return marbles.subscribedFrame !== Infinity; }); - }, - }; - }; - TestScheduler.prototype.flush = function () { - var _this = this; - var hotObservables = this.hotObservables; - while (hotObservables.length > 0) { - hotObservables.shift().setup(); - } - _super.prototype.flush.call(this); - this.flushTests = this.flushTests.filter(function (test) { - if (test.ready) { - _this.assertDeepEqual(test.actual, test.expected); - return false; - } - return true; - }); - }; - TestScheduler.parseMarblesAsSubscriptions = function (marbles, runMode) { - var _this = this; - if (runMode === void 0) { runMode = false; } - if (typeof marbles !== 'string') { - return new SubscriptionLog_1.SubscriptionLog(Infinity); - } - var characters = __spreadArray([], __read(marbles)); - var len = characters.length; - var groupStart = -1; - var subscriptionFrame = Infinity; - var unsubscriptionFrame = Infinity; - var frame = 0; - var _loop_1 = function (i) { - var nextFrame = frame; - var advanceFrameBy = function (count) { - nextFrame += count * _this.frameTimeFactor; - }; - var c = characters[i]; - switch (c) { - case ' ': - if (!runMode) { - advanceFrameBy(1); - } - break; - case '-': - advanceFrameBy(1); - break; - case '(': - groupStart = frame; - advanceFrameBy(1); - break; - case ')': - groupStart = -1; - advanceFrameBy(1); - break; - case '^': - if (subscriptionFrame !== Infinity) { - throw new Error("found a second subscription point '^' in a " + 'subscription marble diagram. There can only be one.'); - } - subscriptionFrame = groupStart > -1 ? groupStart : frame; - advanceFrameBy(1); - break; - case '!': - if (unsubscriptionFrame !== Infinity) { - throw new Error("found a second unsubscription point '!' in a " + 'subscription marble diagram. There can only be one.'); - } - unsubscriptionFrame = groupStart > -1 ? groupStart : frame; - break; - default: - if (runMode && c.match(/^[0-9]$/)) { - if (i === 0 || characters[i - 1] === ' ') { - var buffer = characters.slice(i).join(''); - var match = buffer.match(/^([0-9]+(?:\.[0-9]+)?)(ms|s|m) /); - if (match) { - i += match[0].length - 1; - var duration = parseFloat(match[1]); - var unit = match[2]; - var durationInMs = void 0; - switch (unit) { - case 'ms': - durationInMs = duration; - break; - case 's': - durationInMs = duration * 1000; - break; - case 'm': - durationInMs = duration * 1000 * 60; - break; - default: - break; - } - advanceFrameBy(durationInMs / this_1.frameTimeFactor); - break; - } - } - } - throw new Error("there can only be '^' and '!' markers in a " + "subscription marble diagram. Found instead '" + c + "'."); - } - frame = nextFrame; - out_i_1 = i; - }; - var this_1 = this, out_i_1; - for (var i = 0; i < len; i++) { - _loop_1(i); - i = out_i_1; - } - if (unsubscriptionFrame < 0) { - return new SubscriptionLog_1.SubscriptionLog(subscriptionFrame); - } - else { - return new SubscriptionLog_1.SubscriptionLog(subscriptionFrame, unsubscriptionFrame); - } - }; - TestScheduler.parseMarbles = function (marbles, values, errorValue, materializeInnerObservables, runMode) { - var _this = this; - if (materializeInnerObservables === void 0) { materializeInnerObservables = false; } - if (runMode === void 0) { runMode = false; } - if (marbles.indexOf('!') !== -1) { - throw new Error('conventional marble diagrams cannot have the ' + 'unsubscription marker "!"'); - } - var characters = __spreadArray([], __read(marbles)); - var len = characters.length; - var testMessages = []; - var subIndex = runMode ? marbles.replace(/^[ ]+/, '').indexOf('^') : marbles.indexOf('^'); - var frame = subIndex === -1 ? 0 : subIndex * -this.frameTimeFactor; - var getValue = typeof values !== 'object' - ? function (x) { return x; } - : function (x) { - if (materializeInnerObservables && values[x] instanceof ColdObservable_1.ColdObservable) { - return values[x].messages; - } - return values[x]; - }; - var groupStart = -1; - var _loop_2 = function (i) { - var nextFrame = frame; - var advanceFrameBy = function (count) { - nextFrame += count * _this.frameTimeFactor; - }; - var notification = void 0; - var c = characters[i]; - switch (c) { - case ' ': - if (!runMode) { - advanceFrameBy(1); - } - break; - case '-': - advanceFrameBy(1); - break; - case '(': - groupStart = frame; - advanceFrameBy(1); - break; - case ')': - groupStart = -1; - advanceFrameBy(1); - break; - case '|': - notification = NotificationFactories_1.COMPLETE_NOTIFICATION; - advanceFrameBy(1); - break; - case '^': - advanceFrameBy(1); - break; - case '#': - notification = NotificationFactories_1.errorNotification(errorValue || 'error'); - advanceFrameBy(1); - break; - default: - if (runMode && c.match(/^[0-9]$/)) { - if (i === 0 || characters[i - 1] === ' ') { - var buffer = characters.slice(i).join(''); - var match = buffer.match(/^([0-9]+(?:\.[0-9]+)?)(ms|s|m) /); - if (match) { - i += match[0].length - 1; - var duration = parseFloat(match[1]); - var unit = match[2]; - var durationInMs = void 0; - switch (unit) { - case 'ms': - durationInMs = duration; - break; - case 's': - durationInMs = duration * 1000; - break; - case 'm': - durationInMs = duration * 1000 * 60; - break; - default: - break; - } - advanceFrameBy(durationInMs / this_2.frameTimeFactor); - break; - } - } - } - notification = NotificationFactories_1.nextNotification(getValue(c)); - advanceFrameBy(1); - break; - } - if (notification) { - testMessages.push({ frame: groupStart > -1 ? groupStart : frame, notification: notification }); - } - frame = nextFrame; - out_i_2 = i; - }; - var this_2 = this, out_i_2; - for (var i = 0; i < len; i++) { - _loop_2(i); - i = out_i_2; - } - return testMessages; - }; - TestScheduler.prototype.createAnimator = function () { - var _this = this; - if (!this.runMode) { - throw new Error('animate() must only be used in run mode'); - } - var lastHandle = 0; - var map; - var delegate = { - requestAnimationFrame: function (callback) { - if (!map) { - throw new Error('animate() was not called within run()'); - } - var handle = ++lastHandle; - map.set(handle, callback); - return handle; - }, - cancelAnimationFrame: function (handle) { - if (!map) { - throw new Error('animate() was not called within run()'); - } - map.delete(handle); - }, - }; - var animate = function (marbles) { - var e_1, _a; - if (map) { - throw new Error('animate() must not be called more than once within run()'); - } - if (/[|#]/.test(marbles)) { - throw new Error('animate() must not complete or error'); - } - map = new Map(); - var messages = TestScheduler.parseMarbles(marbles, undefined, undefined, undefined, true); - try { - for (var messages_1 = __values(messages), messages_1_1 = messages_1.next(); !messages_1_1.done; messages_1_1 = messages_1.next()) { - var message = messages_1_1.value; - _this.schedule(function () { - var e_2, _a; - var now = _this.now(); - var callbacks = Array.from(map.values()); - map.clear(); - try { - for (var callbacks_1 = (e_2 = void 0, __values(callbacks)), callbacks_1_1 = callbacks_1.next(); !callbacks_1_1.done; callbacks_1_1 = callbacks_1.next()) { - var callback = callbacks_1_1.value; - callback(now); - } - } - catch (e_2_1) { e_2 = { error: e_2_1 }; } - finally { - try { - if (callbacks_1_1 && !callbacks_1_1.done && (_a = callbacks_1.return)) _a.call(callbacks_1); - } - finally { if (e_2) throw e_2.error; } - } - }, message.frame); - } - } - catch (e_1_1) { e_1 = { error: e_1_1 }; } - finally { - try { - if (messages_1_1 && !messages_1_1.done && (_a = messages_1.return)) _a.call(messages_1); - } - finally { if (e_1) throw e_1.error; } - } - }; - return { animate: animate, delegate: delegate }; - }; - TestScheduler.prototype.createDelegates = function () { - var _this = this; - var lastHandle = 0; - var scheduleLookup = new Map(); - var run = function () { - var now = _this.now(); - var scheduledRecords = Array.from(scheduleLookup.values()); - var scheduledRecordsDue = scheduledRecords.filter(function (_a) { - var due = _a.due; - return due <= now; - }); - var dueImmediates = scheduledRecordsDue.filter(function (_a) { - var type = _a.type; - return type === 'immediate'; - }); - if (dueImmediates.length > 0) { - var _a = dueImmediates[0], handle = _a.handle, handler = _a.handler; - scheduleLookup.delete(handle); - handler(); - return; - } - var dueIntervals = scheduledRecordsDue.filter(function (_a) { - var type = _a.type; - return type === 'interval'; - }); - if (dueIntervals.length > 0) { - var firstDueInterval = dueIntervals[0]; - var duration = firstDueInterval.duration, handler = firstDueInterval.handler; - firstDueInterval.due = now + duration; - firstDueInterval.subscription = _this.schedule(run, duration); - handler(); - return; - } - var dueTimeouts = scheduledRecordsDue.filter(function (_a) { - var type = _a.type; - return type === 'timeout'; - }); - if (dueTimeouts.length > 0) { - var _b = dueTimeouts[0], handle = _b.handle, handler = _b.handler; - scheduleLookup.delete(handle); - handler(); - return; - } - throw new Error('Expected a due immediate or interval'); - }; - var immediate = { - setImmediate: function (handler) { - var handle = ++lastHandle; - scheduleLookup.set(handle, { - due: _this.now(), - duration: 0, - handle: handle, - handler: handler, - subscription: _this.schedule(run, 0), - type: 'immediate', - }); - return handle; - }, - clearImmediate: function (handle) { - var value = scheduleLookup.get(handle); - if (value) { - value.subscription.unsubscribe(); - scheduleLookup.delete(handle); - } - }, - }; - var interval = { - setInterval: function (handler, duration) { - if (duration === void 0) { duration = 0; } - var handle = ++lastHandle; - scheduleLookup.set(handle, { - due: _this.now() + duration, - duration: duration, - handle: handle, - handler: handler, - subscription: _this.schedule(run, duration), - type: 'interval', - }); - return handle; - }, - clearInterval: function (handle) { - var value = scheduleLookup.get(handle); - if (value) { - value.subscription.unsubscribe(); - scheduleLookup.delete(handle); - } - }, - }; - var timeout = { - setTimeout: function (handler, duration) { - if (duration === void 0) { duration = 0; } - var handle = ++lastHandle; - scheduleLookup.set(handle, { - due: _this.now() + duration, - duration: duration, - handle: handle, - handler: handler, - subscription: _this.schedule(run, duration), - type: 'timeout', - }); - return handle; - }, - clearTimeout: function (handle) { - var value = scheduleLookup.get(handle); - if (value) { - value.subscription.unsubscribe(); - scheduleLookup.delete(handle); - } - }, - }; - return { immediate: immediate, interval: interval, timeout: timeout }; - }; - TestScheduler.prototype.run = function (callback) { - var prevFrameTimeFactor = TestScheduler.frameTimeFactor; - var prevMaxFrames = this.maxFrames; - TestScheduler.frameTimeFactor = 1; - this.maxFrames = Infinity; - this.runMode = true; - var animator = this.createAnimator(); - var delegates = this.createDelegates(); - animationFrameProvider_1.animationFrameProvider.delegate = animator.delegate; - dateTimestampProvider_1.dateTimestampProvider.delegate = this; - immediateProvider_1.immediateProvider.delegate = delegates.immediate; - intervalProvider_1.intervalProvider.delegate = delegates.interval; - timeoutProvider_1.timeoutProvider.delegate = delegates.timeout; - performanceTimestampProvider_1.performanceTimestampProvider.delegate = this; - var helpers = { - cold: this.createColdObservable.bind(this), - hot: this.createHotObservable.bind(this), - flush: this.flush.bind(this), - time: this.createTime.bind(this), - expectObservable: this.expectObservable.bind(this), - expectSubscriptions: this.expectSubscriptions.bind(this), - animate: animator.animate, - }; - try { - var ret = callback(helpers); - this.flush(); - return ret; - } - finally { - TestScheduler.frameTimeFactor = prevFrameTimeFactor; - this.maxFrames = prevMaxFrames; - this.runMode = false; - animationFrameProvider_1.animationFrameProvider.delegate = undefined; - dateTimestampProvider_1.dateTimestampProvider.delegate = undefined; - immediateProvider_1.immediateProvider.delegate = undefined; - intervalProvider_1.intervalProvider.delegate = undefined; - timeoutProvider_1.timeoutProvider.delegate = undefined; - performanceTimestampProvider_1.performanceTimestampProvider.delegate = undefined; - } - }; - TestScheduler.frameTimeFactor = 10; - return TestScheduler; -}(VirtualTimeScheduler_1.VirtualTimeScheduler)); -exports.TestScheduler = TestScheduler; -//# sourceMappingURL=TestScheduler.js.map \ No newline at end of file -- cgit v1.2.3