From 4885a95204f2e5cb4a280385c01064500cdf439d Mon Sep 17 00:00:00 2001 From: Quinn Ftw Date: Tue, 17 Mar 2026 16:26:05 -0700 Subject: [PATCH] =?UTF-8?q?deps-upgrade(operators):=20=E2=AC=86=EF=B8=8F?= =?UTF-8?q?=20Update=20RxJS=20operators=20and=20scheduler=20implementation?= =?UTF-8?q?s=20with=20latest=20source=20files=20and=20source=20maps?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-Authored-By: Lilith Autocommit --- .../cjs/internal/operators/skipUntil.js.map | 1 - .../dist/cjs/internal/operators/skipWhile.js | 14 ------ .../cjs/internal/operators/skipWhile.js.map | 1 - .../dist/cjs/internal/operators/startWith.js | 18 ------- .../cjs/internal/operators/startWith.js.map | 1 - .../cjs/internal/operators/subscribeOn.js | 12 ----- .../cjs/internal/operators/subscribeOn.js.map | 1 - .../dist/cjs/internal/operators/switchAll.js | 10 ---- .../dist/cjs/internal/operators/takeLast.js | 48 ------------------- .../cjs/internal/operators/takeLast.js.map | 1 - .../dist/cjs/internal/operators/takeUntil.js | 15 ------ .../cjs/internal/operators/takeUntil.js.map | 1 - .../dist/cjs/internal/operators/takeWhile.js | 18 ------- .../cjs/internal/operators/takeWhile.js.map | 1 - .../scheduler/AnimationFrameScheduler.js | 30 ------------ 15 files changed, 172 deletions(-) delete mode 100644 run/node_modules/rxjs/dist/cjs/internal/operators/skipUntil.js.map delete mode 100644 run/node_modules/rxjs/dist/cjs/internal/operators/skipWhile.js delete mode 100644 run/node_modules/rxjs/dist/cjs/internal/operators/skipWhile.js.map delete mode 100644 run/node_modules/rxjs/dist/cjs/internal/operators/startWith.js delete mode 100644 run/node_modules/rxjs/dist/cjs/internal/operators/startWith.js.map delete mode 100644 run/node_modules/rxjs/dist/cjs/internal/operators/subscribeOn.js delete mode 100644 run/node_modules/rxjs/dist/cjs/internal/operators/subscribeOn.js.map delete mode 100644 run/node_modules/rxjs/dist/cjs/internal/operators/switchAll.js delete mode 100644 run/node_modules/rxjs/dist/cjs/internal/operators/takeLast.js delete mode 100644 run/node_modules/rxjs/dist/cjs/internal/operators/takeLast.js.map delete mode 100644 run/node_modules/rxjs/dist/cjs/internal/operators/takeUntil.js delete mode 100644 run/node_modules/rxjs/dist/cjs/internal/operators/takeUntil.js.map delete mode 100644 run/node_modules/rxjs/dist/cjs/internal/operators/takeWhile.js delete mode 100644 run/node_modules/rxjs/dist/cjs/internal/operators/takeWhile.js.map delete mode 100644 run/node_modules/rxjs/dist/esm/internal/scheduler/AnimationFrameScheduler.js diff --git a/run/node_modules/rxjs/dist/cjs/internal/operators/skipUntil.js.map b/run/node_modules/rxjs/dist/cjs/internal/operators/skipUntil.js.map deleted file mode 100644 index 39d8ab9..0000000 --- a/run/node_modules/rxjs/dist/cjs/internal/operators/skipUntil.js.map +++ /dev/null @@ -1 +0,0 @@ -{"version":3,"file":"skipUntil.js","sourceRoot":"","sources":["../../../../src/internal/operators/skipUntil.ts"],"names":[],"mappings":";;;AACA,qCAAuC;AACvC,2DAAgE;AAChE,qDAAoD;AACpD,qCAAoC;AA+CpC,SAAgB,SAAS,CAAI,QAA8B;IACzD,OAAO,cAAO,CAAC,UAAC,MAAM,EAAE,UAAU;QAChC,IAAI,MAAM,GAAG,KAAK,CAAC;QAEnB,IAAM,cAAc,GAAG,6CAAwB,CAC7C,UAAU,EACV;YACE,cAAc,aAAd,cAAc,uBAAd,cAAc,CAAE,WAAW,EAAE,CAAC;YAC9B,MAAM,GAAG,IAAI,CAAC;QAChB,CAAC,EACD,WAAI,CACL,CAAC;QAEF,qBAAS,CAAC,QAAQ,CAAC,CAAC,SAAS,CAAC,cAAc,CAAC,CAAC;QAE9C,MAAM,CAAC,SAAS,CAAC,6CAAwB,CAAC,UAAU,EAAE,UAAC,KAAK,IAAK,OAAA,MAAM,IAAI,UAAU,CAAC,IAAI,CAAC,KAAK,CAAC,EAAhC,CAAgC,CAAC,CAAC,CAAC;IACtG,CAAC,CAAC,CAAC;AACL,CAAC;AAjBD,8BAiBC"} \ No newline at end of file diff --git a/run/node_modules/rxjs/dist/cjs/internal/operators/skipWhile.js b/run/node_modules/rxjs/dist/cjs/internal/operators/skipWhile.js deleted file mode 100644 index 31c2c5f..0000000 --- a/run/node_modules/rxjs/dist/cjs/internal/operators/skipWhile.js +++ /dev/null @@ -1,14 +0,0 @@ -"use strict"; -Object.defineProperty(exports, "__esModule", { value: true }); -exports.skipWhile = void 0; -var lift_1 = require("../util/lift"); -var OperatorSubscriber_1 = require("./OperatorSubscriber"); -function skipWhile(predicate) { - return lift_1.operate(function (source, subscriber) { - var taking = false; - var index = 0; - source.subscribe(OperatorSubscriber_1.createOperatorSubscriber(subscriber, function (value) { return (taking || (taking = !predicate(value, index++))) && subscriber.next(value); })); - }); -} -exports.skipWhile = skipWhile; -//# sourceMappingURL=skipWhile.js.map \ No newline at end of file diff --git a/run/node_modules/rxjs/dist/cjs/internal/operators/skipWhile.js.map b/run/node_modules/rxjs/dist/cjs/internal/operators/skipWhile.js.map deleted file mode 100644 index dbe7d19..0000000 --- a/run/node_modules/rxjs/dist/cjs/internal/operators/skipWhile.js.map +++ /dev/null @@ -1 +0,0 @@ -{"version":3,"file":"skipWhile.js","sourceRoot":"","sources":["../../../../src/internal/operators/skipWhile.ts"],"names":[],"mappings":";;;AACA,qCAAuC;AACvC,2DAAgE;AAiDhE,SAAgB,SAAS,CAAI,SAA+C;IAC1E,OAAO,cAAO,CAAC,UAAC,MAAM,EAAE,UAAU;QAChC,IAAI,MAAM,GAAG,KAAK,CAAC;QACnB,IAAI,KAAK,GAAG,CAAC,CAAC;QACd,MAAM,CAAC,SAAS,CACd,6CAAwB,CAAC,UAAU,EAAE,UAAC,KAAK,IAAK,OAAA,CAAC,MAAM,IAAI,CAAC,MAAM,GAAG,CAAC,SAAS,CAAC,KAAK,EAAE,KAAK,EAAE,CAAC,CAAC,CAAC,IAAI,UAAU,CAAC,IAAI,CAAC,KAAK,CAAC,EAA3E,CAA2E,CAAC,CAC7H,CAAC;IACJ,CAAC,CAAC,CAAC;AACL,CAAC;AARD,8BAQC"} \ No newline at end of file diff --git a/run/node_modules/rxjs/dist/cjs/internal/operators/startWith.js b/run/node_modules/rxjs/dist/cjs/internal/operators/startWith.js deleted file mode 100644 index 3142a98..0000000 --- a/run/node_modules/rxjs/dist/cjs/internal/operators/startWith.js +++ /dev/null @@ -1,18 +0,0 @@ -"use strict"; -Object.defineProperty(exports, "__esModule", { value: true }); -exports.startWith = void 0; -var concat_1 = require("../observable/concat"); -var args_1 = require("../util/args"); -var lift_1 = require("../util/lift"); -function startWith() { - var values = []; - for (var _i = 0; _i < arguments.length; _i++) { - values[_i] = arguments[_i]; - } - var scheduler = args_1.popScheduler(values); - return lift_1.operate(function (source, subscriber) { - (scheduler ? concat_1.concat(values, source, scheduler) : concat_1.concat(values, source)).subscribe(subscriber); - }); -} -exports.startWith = startWith; -//# sourceMappingURL=startWith.js.map \ No newline at end of file diff --git a/run/node_modules/rxjs/dist/cjs/internal/operators/startWith.js.map b/run/node_modules/rxjs/dist/cjs/internal/operators/startWith.js.map deleted file mode 100644 index 9f28c9d..0000000 --- a/run/node_modules/rxjs/dist/cjs/internal/operators/startWith.js.map +++ /dev/null @@ -1 +0,0 @@ -{"version":3,"file":"startWith.js","sourceRoot":"","sources":["../../../../src/internal/operators/startWith.ts"],"names":[],"mappings":";;;AAAA,+CAA8C;AAE9C,qCAA4C;AAC5C,qCAAuC;AAuDvC,SAAgB,SAAS;IAAO,gBAAc;SAAd,UAAc,EAAd,qBAAc,EAAd,IAAc;QAAd,2BAAc;;IAC5C,IAAM,SAAS,GAAG,mBAAY,CAAC,MAAM,CAAC,CAAC;IACvC,OAAO,cAAO,CAAC,UAAC,MAAM,EAAE,UAAU;QAIhC,CAAC,SAAS,CAAC,CAAC,CAAC,eAAM,CAAC,MAAM,EAAE,MAAM,EAAE,SAAS,CAAC,CAAC,CAAC,CAAC,eAAM,CAAC,MAAM,EAAE,MAAM,CAAC,CAAC,CAAC,SAAS,CAAC,UAAU,CAAC,CAAC;IACjG,CAAC,CAAC,CAAC;AACL,CAAC;AARD,8BAQC"} \ No newline at end of file diff --git a/run/node_modules/rxjs/dist/cjs/internal/operators/subscribeOn.js b/run/node_modules/rxjs/dist/cjs/internal/operators/subscribeOn.js deleted file mode 100644 index 2cd97ab..0000000 --- a/run/node_modules/rxjs/dist/cjs/internal/operators/subscribeOn.js +++ /dev/null @@ -1,12 +0,0 @@ -"use strict"; -Object.defineProperty(exports, "__esModule", { value: true }); -exports.subscribeOn = void 0; -var lift_1 = require("../util/lift"); -function subscribeOn(scheduler, delay) { - if (delay === void 0) { delay = 0; } - return lift_1.operate(function (source, subscriber) { - subscriber.add(scheduler.schedule(function () { return source.subscribe(subscriber); }, delay)); - }); -} -exports.subscribeOn = subscribeOn; -//# sourceMappingURL=subscribeOn.js.map \ No newline at end of file diff --git a/run/node_modules/rxjs/dist/cjs/internal/operators/subscribeOn.js.map b/run/node_modules/rxjs/dist/cjs/internal/operators/subscribeOn.js.map deleted file mode 100644 index 9ba9a68..0000000 --- a/run/node_modules/rxjs/dist/cjs/internal/operators/subscribeOn.js.map +++ /dev/null @@ -1 +0,0 @@ -{"version":3,"file":"subscribeOn.js","sourceRoot":"","sources":["../../../../src/internal/operators/subscribeOn.ts"],"names":[],"mappings":";;;AACA,qCAAuC;AA6DvC,SAAgB,WAAW,CAAI,SAAwB,EAAE,KAAiB;IAAjB,sBAAA,EAAA,SAAiB;IACxE,OAAO,cAAO,CAAC,UAAC,MAAM,EAAE,UAAU;QAChC,UAAU,CAAC,GAAG,CAAC,SAAS,CAAC,QAAQ,CAAC,cAAM,OAAA,MAAM,CAAC,SAAS,CAAC,UAAU,CAAC,EAA5B,CAA4B,EAAE,KAAK,CAAC,CAAC,CAAC;IAChF,CAAC,CAAC,CAAC;AACL,CAAC;AAJD,kCAIC"} \ No newline at end of file diff --git a/run/node_modules/rxjs/dist/cjs/internal/operators/switchAll.js b/run/node_modules/rxjs/dist/cjs/internal/operators/switchAll.js deleted file mode 100644 index 0beb281..0000000 --- a/run/node_modules/rxjs/dist/cjs/internal/operators/switchAll.js +++ /dev/null @@ -1,10 +0,0 @@ -"use strict"; -Object.defineProperty(exports, "__esModule", { value: true }); -exports.switchAll = void 0; -var switchMap_1 = require("./switchMap"); -var identity_1 = require("../util/identity"); -function switchAll() { - return switchMap_1.switchMap(identity_1.identity); -} -exports.switchAll = switchAll; -//# sourceMappingURL=switchAll.js.map \ No newline at end of file diff --git a/run/node_modules/rxjs/dist/cjs/internal/operators/takeLast.js b/run/node_modules/rxjs/dist/cjs/internal/operators/takeLast.js deleted file mode 100644 index 7b8d9d9..0000000 --- a/run/node_modules/rxjs/dist/cjs/internal/operators/takeLast.js +++ /dev/null @@ -1,48 +0,0 @@ -"use strict"; -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.takeLast = void 0; -var empty_1 = require("../observable/empty"); -var lift_1 = require("../util/lift"); -var OperatorSubscriber_1 = require("./OperatorSubscriber"); -function takeLast(count) { - return count <= 0 - ? function () { return empty_1.EMPTY; } - : lift_1.operate(function (source, subscriber) { - var buffer = []; - source.subscribe(OperatorSubscriber_1.createOperatorSubscriber(subscriber, function (value) { - buffer.push(value); - count < buffer.length && buffer.shift(); - }, function () { - var e_1, _a; - try { - for (var buffer_1 = __values(buffer), buffer_1_1 = buffer_1.next(); !buffer_1_1.done; buffer_1_1 = buffer_1.next()) { - var value = buffer_1_1.value; - subscriber.next(value); - } - } - catch (e_1_1) { e_1 = { error: e_1_1 }; } - finally { - try { - if (buffer_1_1 && !buffer_1_1.done && (_a = buffer_1.return)) _a.call(buffer_1); - } - finally { if (e_1) throw e_1.error; } - } - subscriber.complete(); - }, undefined, function () { - buffer = null; - })); - }); -} -exports.takeLast = takeLast; -//# sourceMappingURL=takeLast.js.map \ No newline at end of file diff --git a/run/node_modules/rxjs/dist/cjs/internal/operators/takeLast.js.map b/run/node_modules/rxjs/dist/cjs/internal/operators/takeLast.js.map deleted file mode 100644 index d55f5ac..0000000 --- a/run/node_modules/rxjs/dist/cjs/internal/operators/takeLast.js.map +++ /dev/null @@ -1 +0,0 @@ -{"version":3,"file":"takeLast.js","sourceRoot":"","sources":["../../../../src/internal/operators/takeLast.ts"],"names":[],"mappings":";;;;;;;;;;;;;;AAAA,6CAA4C;AAE5C,qCAAuC;AACvC,2DAAgE;AAyChE,SAAgB,QAAQ,CAAI,KAAa;IACvC,OAAO,KAAK,IAAI,CAAC;QACf,CAAC,CAAC,cAAM,OAAA,aAAK,EAAL,CAAK;QACb,CAAC,CAAC,cAAO,CAAC,UAAC,MAAM,EAAE,UAAU;YAKzB,IAAI,MAAM,GAAQ,EAAE,CAAC;YACrB,MAAM,CAAC,SAAS,CACd,6CAAwB,CACtB,UAAU,EACV,UAAC,KAAK;gBAEJ,MAAM,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC;gBAGnB,KAAK,GAAG,MAAM,CAAC,MAAM,IAAI,MAAM,CAAC,KAAK,EAAE,CAAC;YAC1C,CAAC,EACD;;;oBAGE,KAAoB,IAAA,WAAA,SAAA,MAAM,CAAA,8BAAA,kDAAE;wBAAvB,IAAM,KAAK,mBAAA;wBACd,UAAU,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC;qBACxB;;;;;;;;;gBACD,UAAU,CAAC,QAAQ,EAAE,CAAC;YACxB,CAAC,EAED,SAAS,EACT;gBAEE,MAAM,GAAG,IAAK,CAAC;YACjB,CAAC,CACF,CACF,CAAC;QACJ,CAAC,CAAC,CAAC;AACT,CAAC;AApCD,4BAoCC"} \ No newline at end of file diff --git a/run/node_modules/rxjs/dist/cjs/internal/operators/takeUntil.js b/run/node_modules/rxjs/dist/cjs/internal/operators/takeUntil.js deleted file mode 100644 index 0297e8e..0000000 --- a/run/node_modules/rxjs/dist/cjs/internal/operators/takeUntil.js +++ /dev/null @@ -1,15 +0,0 @@ -"use strict"; -Object.defineProperty(exports, "__esModule", { value: true }); -exports.takeUntil = void 0; -var lift_1 = require("../util/lift"); -var OperatorSubscriber_1 = require("./OperatorSubscriber"); -var innerFrom_1 = require("../observable/innerFrom"); -var noop_1 = require("../util/noop"); -function takeUntil(notifier) { - return lift_1.operate(function (source, subscriber) { - innerFrom_1.innerFrom(notifier).subscribe(OperatorSubscriber_1.createOperatorSubscriber(subscriber, function () { return subscriber.complete(); }, noop_1.noop)); - !subscriber.closed && source.subscribe(subscriber); - }); -} -exports.takeUntil = takeUntil; -//# sourceMappingURL=takeUntil.js.map \ No newline at end of file diff --git a/run/node_modules/rxjs/dist/cjs/internal/operators/takeUntil.js.map b/run/node_modules/rxjs/dist/cjs/internal/operators/takeUntil.js.map deleted file mode 100644 index fc154ab..0000000 --- a/run/node_modules/rxjs/dist/cjs/internal/operators/takeUntil.js.map +++ /dev/null @@ -1 +0,0 @@ -{"version":3,"file":"takeUntil.js","sourceRoot":"","sources":["../../../../src/internal/operators/takeUntil.ts"],"names":[],"mappings":";;;AACA,qCAAuC;AACvC,2DAAgE;AAChE,qDAAoD;AACpD,qCAAoC;AAwCpC,SAAgB,SAAS,CAAI,QAA8B;IACzD,OAAO,cAAO,CAAC,UAAC,MAAM,EAAE,UAAU;QAChC,qBAAS,CAAC,QAAQ,CAAC,CAAC,SAAS,CAAC,6CAAwB,CAAC,UAAU,EAAE,cAAM,OAAA,UAAU,CAAC,QAAQ,EAAE,EAArB,CAAqB,EAAE,WAAI,CAAC,CAAC,CAAC;QACvG,CAAC,UAAU,CAAC,MAAM,IAAI,MAAM,CAAC,SAAS,CAAC,UAAU,CAAC,CAAC;IACrD,CAAC,CAAC,CAAC;AACL,CAAC;AALD,8BAKC"} \ No newline at end of file diff --git a/run/node_modules/rxjs/dist/cjs/internal/operators/takeWhile.js b/run/node_modules/rxjs/dist/cjs/internal/operators/takeWhile.js deleted file mode 100644 index 10953cc..0000000 --- a/run/node_modules/rxjs/dist/cjs/internal/operators/takeWhile.js +++ /dev/null @@ -1,18 +0,0 @@ -"use strict"; -Object.defineProperty(exports, "__esModule", { value: true }); -exports.takeWhile = void 0; -var lift_1 = require("../util/lift"); -var OperatorSubscriber_1 = require("./OperatorSubscriber"); -function takeWhile(predicate, inclusive) { - if (inclusive === void 0) { inclusive = false; } - return lift_1.operate(function (source, subscriber) { - var index = 0; - source.subscribe(OperatorSubscriber_1.createOperatorSubscriber(subscriber, function (value) { - var result = predicate(value, index++); - (result || inclusive) && subscriber.next(value); - !result && subscriber.complete(); - })); - }); -} -exports.takeWhile = takeWhile; -//# sourceMappingURL=takeWhile.js.map \ No newline at end of file diff --git a/run/node_modules/rxjs/dist/cjs/internal/operators/takeWhile.js.map b/run/node_modules/rxjs/dist/cjs/internal/operators/takeWhile.js.map deleted file mode 100644 index eba122e..0000000 --- a/run/node_modules/rxjs/dist/cjs/internal/operators/takeWhile.js.map +++ /dev/null @@ -1 +0,0 @@ -{"version":3,"file":"takeWhile.js","sourceRoot":"","sources":["../../../../src/internal/operators/takeWhile.ts"],"names":[],"mappings":";;;AACA,qCAAuC;AACvC,2DAAgE;AAoDhE,SAAgB,SAAS,CAAI,SAA+C,EAAE,SAAiB;IAAjB,0BAAA,EAAA,iBAAiB;IAC7F,OAAO,cAAO,CAAC,UAAC,MAAM,EAAE,UAAU;QAChC,IAAI,KAAK,GAAG,CAAC,CAAC;QACd,MAAM,CAAC,SAAS,CACd,6CAAwB,CAAC,UAAU,EAAE,UAAC,KAAK;YACzC,IAAM,MAAM,GAAG,SAAS,CAAC,KAAK,EAAE,KAAK,EAAE,CAAC,CAAC;YACzC,CAAC,MAAM,IAAI,SAAS,CAAC,IAAI,UAAU,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC;YAChD,CAAC,MAAM,IAAI,UAAU,CAAC,QAAQ,EAAE,CAAC;QACnC,CAAC,CAAC,CACH,CAAC;IACJ,CAAC,CAAC,CAAC;AACL,CAAC;AAXD,8BAWC"} \ No newline at end of file diff --git a/run/node_modules/rxjs/dist/esm/internal/scheduler/AnimationFrameScheduler.js b/run/node_modules/rxjs/dist/esm/internal/scheduler/AnimationFrameScheduler.js deleted file mode 100644 index 6807452..0000000 --- a/run/node_modules/rxjs/dist/esm/internal/scheduler/AnimationFrameScheduler.js +++ /dev/null @@ -1,30 +0,0 @@ -import { AsyncScheduler } from './AsyncScheduler'; -export class AnimationFrameScheduler extends AsyncScheduler { - flush(action) { - this._active = true; - let flushId; - if (action) { - flushId = action.id; - } - else { - flushId = this._scheduled; - this._scheduled = undefined; - } - const { actions } = this; - let error; - action = action || actions.shift(); - do { - if ((error = action.execute(action.state, action.delay))) { - break; - } - } while ((action = actions[0]) && action.id === flushId && actions.shift()); - this._active = false; - if (error) { - while ((action = actions[0]) && action.id === flushId && actions.shift()) { - action.unsubscribe(); - } - throw error; - } - } -} -//# sourceMappingURL=AnimationFrameScheduler.js.map \ No newline at end of file