aboutsummaryrefslogtreecommitdiffstats
path: root/node_modules/rxjs/dist/cjs/internal/scheduled
diff options
context:
space:
mode:
authorPinapelz <yukais@pinapelz.com>2025-06-29 11:49:28 -0700
committerPinapelz <yukais@pinapelz.com>2025-06-29 11:49:28 -0700
commitd55b767039605256c736166a942a9138e3eacfd7 (patch)
tree947063b634c50d438a794325f13275e134aa5993 /node_modules/rxjs/dist/cjs/internal/scheduled
parent864ce67d89c77d8ef9c3361f80d619853abcf91c (diff)
remove dev node_modules (oops)
Diffstat (limited to 'node_modules/rxjs/dist/cjs/internal/scheduled')
-rw-r--r--node_modules/rxjs/dist/cjs/internal/scheduled/scheduleArray.js22
-rw-r--r--node_modules/rxjs/dist/cjs/internal/scheduled/scheduleArray.js.map1
-rw-r--r--node_modules/rxjs/dist/cjs/internal/scheduled/scheduleAsyncIterable.js27
-rw-r--r--node_modules/rxjs/dist/cjs/internal/scheduled/scheduleAsyncIterable.js.map1
-rw-r--r--node_modules/rxjs/dist/cjs/internal/scheduled/scheduleIterable.js36
-rw-r--r--node_modules/rxjs/dist/cjs/internal/scheduled/scheduleIterable.js.map1
-rw-r--r--node_modules/rxjs/dist/cjs/internal/scheduled/scheduleObservable.js11
-rw-r--r--node_modules/rxjs/dist/cjs/internal/scheduled/scheduleObservable.js.map1
-rw-r--r--node_modules/rxjs/dist/cjs/internal/scheduled/schedulePromise.js11
-rw-r--r--node_modules/rxjs/dist/cjs/internal/scheduled/schedulePromise.js.map1
-rw-r--r--node_modules/rxjs/dist/cjs/internal/scheduled/scheduleReadableStreamLike.js10
-rw-r--r--node_modules/rxjs/dist/cjs/internal/scheduled/scheduleReadableStreamLike.js.map1
-rw-r--r--node_modules/rxjs/dist/cjs/internal/scheduled/scheduled.js41
-rw-r--r--node_modules/rxjs/dist/cjs/internal/scheduled/scheduled.js.map1
14 files changed, 0 insertions, 165 deletions
diff --git a/node_modules/rxjs/dist/cjs/internal/scheduled/scheduleArray.js b/node_modules/rxjs/dist/cjs/internal/scheduled/scheduleArray.js
deleted file mode 100644
index 9af85a7..0000000
--- a/node_modules/rxjs/dist/cjs/internal/scheduled/scheduleArray.js
+++ /dev/null
@@ -1,22 +0,0 @@
-"use strict";
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.scheduleArray = void 0;
-var Observable_1 = require("../Observable");
-function scheduleArray(input, scheduler) {
- return new Observable_1.Observable(function (subscriber) {
- var i = 0;
- return scheduler.schedule(function () {
- if (i === input.length) {
- subscriber.complete();
- }
- else {
- subscriber.next(input[i++]);
- if (!subscriber.closed) {
- this.schedule();
- }
- }
- });
- });
-}
-exports.scheduleArray = scheduleArray;
-//# sourceMappingURL=scheduleArray.js.map \ No newline at end of file
diff --git a/node_modules/rxjs/dist/cjs/internal/scheduled/scheduleArray.js.map b/node_modules/rxjs/dist/cjs/internal/scheduled/scheduleArray.js.map
deleted file mode 100644
index b42b310..0000000
--- a/node_modules/rxjs/dist/cjs/internal/scheduled/scheduleArray.js.map
+++ /dev/null
@@ -1 +0,0 @@
-{"version":3,"file":"scheduleArray.js","sourceRoot":"","sources":["../../../../src/internal/scheduled/scheduleArray.ts"],"names":[],"mappings":";;;AAAA,4CAA2C;AAG3C,SAAgB,aAAa,CAAI,KAAmB,EAAE,SAAwB;IAC5E,OAAO,IAAI,uBAAU,CAAI,UAAC,UAAU;QAElC,IAAI,CAAC,GAAG,CAAC,CAAC;QAEV,OAAO,SAAS,CAAC,QAAQ,CAAC;YACxB,IAAI,CAAC,KAAK,KAAK,CAAC,MAAM,EAAE;gBAGtB,UAAU,CAAC,QAAQ,EAAE,CAAC;aACvB;iBAAM;gBAGL,UAAU,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC,EAAE,CAAC,CAAC,CAAC;gBAI5B,IAAI,CAAC,UAAU,CAAC,MAAM,EAAE;oBACtB,IAAI,CAAC,QAAQ,EAAE,CAAC;iBACjB;aACF;QACH,CAAC,CAAC,CAAC;IACL,CAAC,CAAC,CAAC;AACL,CAAC;AAvBD,sCAuBC"} \ No newline at end of file
diff --git a/node_modules/rxjs/dist/cjs/internal/scheduled/scheduleAsyncIterable.js b/node_modules/rxjs/dist/cjs/internal/scheduled/scheduleAsyncIterable.js
deleted file mode 100644
index 4729896..0000000
--- a/node_modules/rxjs/dist/cjs/internal/scheduled/scheduleAsyncIterable.js
+++ /dev/null
@@ -1,27 +0,0 @@
-"use strict";
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.scheduleAsyncIterable = void 0;
-var Observable_1 = require("../Observable");
-var executeSchedule_1 = require("../util/executeSchedule");
-function scheduleAsyncIterable(input, scheduler) {
- if (!input) {
- throw new Error('Iterable cannot be null');
- }
- return new Observable_1.Observable(function (subscriber) {
- executeSchedule_1.executeSchedule(subscriber, scheduler, function () {
- var iterator = input[Symbol.asyncIterator]();
- executeSchedule_1.executeSchedule(subscriber, scheduler, function () {
- iterator.next().then(function (result) {
- if (result.done) {
- subscriber.complete();
- }
- else {
- subscriber.next(result.value);
- }
- });
- }, 0, true);
- });
- });
-}
-exports.scheduleAsyncIterable = scheduleAsyncIterable;
-//# sourceMappingURL=scheduleAsyncIterable.js.map \ No newline at end of file
diff --git a/node_modules/rxjs/dist/cjs/internal/scheduled/scheduleAsyncIterable.js.map b/node_modules/rxjs/dist/cjs/internal/scheduled/scheduleAsyncIterable.js.map
deleted file mode 100644
index 1dcd219..0000000
--- a/node_modules/rxjs/dist/cjs/internal/scheduled/scheduleAsyncIterable.js.map
+++ /dev/null
@@ -1 +0,0 @@
-{"version":3,"file":"scheduleAsyncIterable.js","sourceRoot":"","sources":["../../../../src/internal/scheduled/scheduleAsyncIterable.ts"],"names":[],"mappings":";;;AACA,4CAA2C;AAC3C,2DAA0D;AAE1D,SAAgB,qBAAqB,CAAI,KAAuB,EAAE,SAAwB;IACxF,IAAI,CAAC,KAAK,EAAE;QACV,MAAM,IAAI,KAAK,CAAC,yBAAyB,CAAC,CAAC;KAC5C;IACD,OAAO,IAAI,uBAAU,CAAI,UAAC,UAAU;QAClC,iCAAe,CAAC,UAAU,EAAE,SAAS,EAAE;YACrC,IAAM,QAAQ,GAAG,KAAK,CAAC,MAAM,CAAC,aAAa,CAAC,EAAE,CAAC;YAC/C,iCAAe,CACb,UAAU,EACV,SAAS,EACT;gBACE,QAAQ,CAAC,IAAI,EAAE,CAAC,IAAI,CAAC,UAAC,MAAM;oBAC1B,IAAI,MAAM,CAAC,IAAI,EAAE;wBAGf,UAAU,CAAC,QAAQ,EAAE,CAAC;qBACvB;yBAAM;wBACL,UAAU,CAAC,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,CAAC;qBAC/B;gBACH,CAAC,CAAC,CAAC;YACL,CAAC,EACD,CAAC,EACD,IAAI,CACL,CAAC;QACJ,CAAC,CAAC,CAAC;IACL,CAAC,CAAC,CAAC;AACL,CAAC;AA1BD,sDA0BC"} \ No newline at end of file
diff --git a/node_modules/rxjs/dist/cjs/internal/scheduled/scheduleIterable.js b/node_modules/rxjs/dist/cjs/internal/scheduled/scheduleIterable.js
deleted file mode 100644
index 0444efe..0000000
--- a/node_modules/rxjs/dist/cjs/internal/scheduled/scheduleIterable.js
+++ /dev/null
@@ -1,36 +0,0 @@
-"use strict";
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.scheduleIterable = void 0;
-var Observable_1 = require("../Observable");
-var iterator_1 = require("../symbol/iterator");
-var isFunction_1 = require("../util/isFunction");
-var executeSchedule_1 = require("../util/executeSchedule");
-function scheduleIterable(input, scheduler) {
- return new Observable_1.Observable(function (subscriber) {
- var iterator;
- executeSchedule_1.executeSchedule(subscriber, scheduler, function () {
- iterator = input[iterator_1.iterator]();
- executeSchedule_1.executeSchedule(subscriber, scheduler, function () {
- var _a;
- var value;
- var done;
- try {
- (_a = iterator.next(), value = _a.value, done = _a.done);
- }
- catch (err) {
- subscriber.error(err);
- return;
- }
- if (done) {
- subscriber.complete();
- }
- else {
- subscriber.next(value);
- }
- }, 0, true);
- });
- return function () { return isFunction_1.isFunction(iterator === null || iterator === void 0 ? void 0 : iterator.return) && iterator.return(); };
- });
-}
-exports.scheduleIterable = scheduleIterable;
-//# sourceMappingURL=scheduleIterable.js.map \ No newline at end of file
diff --git a/node_modules/rxjs/dist/cjs/internal/scheduled/scheduleIterable.js.map b/node_modules/rxjs/dist/cjs/internal/scheduled/scheduleIterable.js.map
deleted file mode 100644
index ead78f7..0000000
--- a/node_modules/rxjs/dist/cjs/internal/scheduled/scheduleIterable.js.map
+++ /dev/null
@@ -1 +0,0 @@
-{"version":3,"file":"scheduleIterable.js","sourceRoot":"","sources":["../../../../src/internal/scheduled/scheduleIterable.ts"],"names":[],"mappings":";;;AAAA,4CAA2C;AAE3C,+CAAiE;AACjE,iDAAgD;AAChD,2DAA0D;AAO1D,SAAgB,gBAAgB,CAAI,KAAkB,EAAE,SAAwB;IAC9E,OAAO,IAAI,uBAAU,CAAI,UAAC,UAAU;QAClC,IAAI,QAAwB,CAAC;QAK7B,iCAAe,CAAC,UAAU,EAAE,SAAS,EAAE;YAErC,QAAQ,GAAI,KAAa,CAAC,mBAAe,CAAC,EAAE,CAAC;YAE7C,iCAAe,CACb,UAAU,EACV,SAAS,EACT;;gBACE,IAAI,KAAQ,CAAC;gBACb,IAAI,IAAyB,CAAC;gBAC9B,IAAI;oBAEF,CAAC,KAAkB,QAAQ,CAAC,IAAI,EAAE,EAA/B,KAAK,WAAA,EAAE,IAAI,UAAA,CAAqB,CAAC;iBACrC;gBAAC,OAAO,GAAG,EAAE;oBAEZ,UAAU,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC;oBACtB,OAAO;iBACR;gBAED,IAAI,IAAI,EAAE;oBAKR,UAAU,CAAC,QAAQ,EAAE,CAAC;iBACvB;qBAAM;oBAEL,UAAU,CAAC,IAAI,CAAC,KAAK,CAAC,CAAC;iBACxB;YACH,CAAC,EACD,CAAC,EACD,IAAI,CACL,CAAC;QACJ,CAAC,CAAC,CAAC;QAMH,OAAO,cAAM,OAAA,uBAAU,CAAC,QAAQ,aAAR,QAAQ,uBAAR,QAAQ,CAAE,MAAM,CAAC,IAAI,QAAQ,CAAC,MAAM,EAAE,EAAjD,CAAiD,CAAC;IACjE,CAAC,CAAC,CAAC;AACL,CAAC;AAhDD,4CAgDC"} \ No newline at end of file
diff --git a/node_modules/rxjs/dist/cjs/internal/scheduled/scheduleObservable.js b/node_modules/rxjs/dist/cjs/internal/scheduled/scheduleObservable.js
deleted file mode 100644
index 90ee012..0000000
--- a/node_modules/rxjs/dist/cjs/internal/scheduled/scheduleObservable.js
+++ /dev/null
@@ -1,11 +0,0 @@
-"use strict";
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.scheduleObservable = void 0;
-var innerFrom_1 = require("../observable/innerFrom");
-var observeOn_1 = require("../operators/observeOn");
-var subscribeOn_1 = require("../operators/subscribeOn");
-function scheduleObservable(input, scheduler) {
- return innerFrom_1.innerFrom(input).pipe(subscribeOn_1.subscribeOn(scheduler), observeOn_1.observeOn(scheduler));
-}
-exports.scheduleObservable = scheduleObservable;
-//# sourceMappingURL=scheduleObservable.js.map \ No newline at end of file
diff --git a/node_modules/rxjs/dist/cjs/internal/scheduled/scheduleObservable.js.map b/node_modules/rxjs/dist/cjs/internal/scheduled/scheduleObservable.js.map
deleted file mode 100644
index 3cfdc17..0000000
--- a/node_modules/rxjs/dist/cjs/internal/scheduled/scheduleObservable.js.map
+++ /dev/null
@@ -1 +0,0 @@
-{"version":3,"file":"scheduleObservable.js","sourceRoot":"","sources":["../../../../src/internal/scheduled/scheduleObservable.ts"],"names":[],"mappings":";;;AAAA,qDAAoD;AACpD,oDAAmD;AACnD,wDAAuD;AAGvD,SAAgB,kBAAkB,CAAI,KAA2B,EAAE,SAAwB;IACzF,OAAO,qBAAS,CAAC,KAAK,CAAC,CAAC,IAAI,CAAC,yBAAW,CAAC,SAAS,CAAC,EAAE,qBAAS,CAAC,SAAS,CAAC,CAAC,CAAC;AAC7E,CAAC;AAFD,gDAEC"} \ No newline at end of file
diff --git a/node_modules/rxjs/dist/cjs/internal/scheduled/schedulePromise.js b/node_modules/rxjs/dist/cjs/internal/scheduled/schedulePromise.js
deleted file mode 100644
index 37629d4..0000000
--- a/node_modules/rxjs/dist/cjs/internal/scheduled/schedulePromise.js
+++ /dev/null
@@ -1,11 +0,0 @@
-"use strict";
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.schedulePromise = void 0;
-var innerFrom_1 = require("../observable/innerFrom");
-var observeOn_1 = require("../operators/observeOn");
-var subscribeOn_1 = require("../operators/subscribeOn");
-function schedulePromise(input, scheduler) {
- return innerFrom_1.innerFrom(input).pipe(subscribeOn_1.subscribeOn(scheduler), observeOn_1.observeOn(scheduler));
-}
-exports.schedulePromise = schedulePromise;
-//# sourceMappingURL=schedulePromise.js.map \ No newline at end of file
diff --git a/node_modules/rxjs/dist/cjs/internal/scheduled/schedulePromise.js.map b/node_modules/rxjs/dist/cjs/internal/scheduled/schedulePromise.js.map
deleted file mode 100644
index f6d7bcf..0000000
--- a/node_modules/rxjs/dist/cjs/internal/scheduled/schedulePromise.js.map
+++ /dev/null
@@ -1 +0,0 @@
-{"version":3,"file":"schedulePromise.js","sourceRoot":"","sources":["../../../../src/internal/scheduled/schedulePromise.ts"],"names":[],"mappings":";;;AAAA,qDAAoD;AACpD,oDAAmD;AACnD,wDAAuD;AAGvD,SAAgB,eAAe,CAAI,KAAqB,EAAE,SAAwB;IAChF,OAAO,qBAAS,CAAC,KAAK,CAAC,CAAC,IAAI,CAAC,yBAAW,CAAC,SAAS,CAAC,EAAE,qBAAS,CAAC,SAAS,CAAC,CAAC,CAAC;AAC7E,CAAC;AAFD,0CAEC"} \ No newline at end of file
diff --git a/node_modules/rxjs/dist/cjs/internal/scheduled/scheduleReadableStreamLike.js b/node_modules/rxjs/dist/cjs/internal/scheduled/scheduleReadableStreamLike.js
deleted file mode 100644
index 067ca61..0000000
--- a/node_modules/rxjs/dist/cjs/internal/scheduled/scheduleReadableStreamLike.js
+++ /dev/null
@@ -1,10 +0,0 @@
-"use strict";
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.scheduleReadableStreamLike = void 0;
-var scheduleAsyncIterable_1 = require("./scheduleAsyncIterable");
-var isReadableStreamLike_1 = require("../util/isReadableStreamLike");
-function scheduleReadableStreamLike(input, scheduler) {
- return scheduleAsyncIterable_1.scheduleAsyncIterable(isReadableStreamLike_1.readableStreamLikeToAsyncGenerator(input), scheduler);
-}
-exports.scheduleReadableStreamLike = scheduleReadableStreamLike;
-//# sourceMappingURL=scheduleReadableStreamLike.js.map \ No newline at end of file
diff --git a/node_modules/rxjs/dist/cjs/internal/scheduled/scheduleReadableStreamLike.js.map b/node_modules/rxjs/dist/cjs/internal/scheduled/scheduleReadableStreamLike.js.map
deleted file mode 100644
index 00be810..0000000
--- a/node_modules/rxjs/dist/cjs/internal/scheduled/scheduleReadableStreamLike.js.map
+++ /dev/null
@@ -1 +0,0 @@
-{"version":3,"file":"scheduleReadableStreamLike.js","sourceRoot":"","sources":["../../../../src/internal/scheduled/scheduleReadableStreamLike.ts"],"names":[],"mappings":";;;AAEA,iEAAgE;AAChE,qEAAkF;AAElF,SAAgB,0BAA0B,CAAI,KAA4B,EAAE,SAAwB;IAClG,OAAO,6CAAqB,CAAC,yDAAkC,CAAC,KAAK,CAAC,EAAE,SAAS,CAAC,CAAC;AACrF,CAAC;AAFD,gEAEC"} \ No newline at end of file
diff --git a/node_modules/rxjs/dist/cjs/internal/scheduled/scheduled.js b/node_modules/rxjs/dist/cjs/internal/scheduled/scheduled.js
deleted file mode 100644
index 8b2564b..0000000
--- a/node_modules/rxjs/dist/cjs/internal/scheduled/scheduled.js
+++ /dev/null
@@ -1,41 +0,0 @@
-"use strict";
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.scheduled = void 0;
-var scheduleObservable_1 = require("./scheduleObservable");
-var schedulePromise_1 = require("./schedulePromise");
-var scheduleArray_1 = require("./scheduleArray");
-var scheduleIterable_1 = require("./scheduleIterable");
-var scheduleAsyncIterable_1 = require("./scheduleAsyncIterable");
-var isInteropObservable_1 = require("../util/isInteropObservable");
-var isPromise_1 = require("../util/isPromise");
-var isArrayLike_1 = require("../util/isArrayLike");
-var isIterable_1 = require("../util/isIterable");
-var isAsyncIterable_1 = require("../util/isAsyncIterable");
-var throwUnobservableError_1 = require("../util/throwUnobservableError");
-var isReadableStreamLike_1 = require("../util/isReadableStreamLike");
-var scheduleReadableStreamLike_1 = require("./scheduleReadableStreamLike");
-function scheduled(input, scheduler) {
- if (input != null) {
- if (isInteropObservable_1.isInteropObservable(input)) {
- return scheduleObservable_1.scheduleObservable(input, scheduler);
- }
- if (isArrayLike_1.isArrayLike(input)) {
- return scheduleArray_1.scheduleArray(input, scheduler);
- }
- if (isPromise_1.isPromise(input)) {
- return schedulePromise_1.schedulePromise(input, scheduler);
- }
- if (isAsyncIterable_1.isAsyncIterable(input)) {
- return scheduleAsyncIterable_1.scheduleAsyncIterable(input, scheduler);
- }
- if (isIterable_1.isIterable(input)) {
- return scheduleIterable_1.scheduleIterable(input, scheduler);
- }
- if (isReadableStreamLike_1.isReadableStreamLike(input)) {
- return scheduleReadableStreamLike_1.scheduleReadableStreamLike(input, scheduler);
- }
- }
- throw throwUnobservableError_1.createInvalidObservableTypeError(input);
-}
-exports.scheduled = scheduled;
-//# sourceMappingURL=scheduled.js.map \ No newline at end of file
diff --git a/node_modules/rxjs/dist/cjs/internal/scheduled/scheduled.js.map b/node_modules/rxjs/dist/cjs/internal/scheduled/scheduled.js.map
deleted file mode 100644
index bffb909..0000000
--- a/node_modules/rxjs/dist/cjs/internal/scheduled/scheduled.js.map
+++ /dev/null
@@ -1 +0,0 @@
-{"version":3,"file":"scheduled.js","sourceRoot":"","sources":["../../../../src/internal/scheduled/scheduled.ts"],"names":[],"mappings":";;;AAAA,2DAA0D;AAC1D,qDAAoD;AACpD,iDAAgD;AAChD,uDAAsD;AACtD,iEAAgE;AAChE,mEAAkE;AAClE,+CAA8C;AAC9C,mDAAkD;AAClD,iDAAgD;AAGhD,2DAA0D;AAC1D,yEAAkF;AAClF,qEAAoE;AACpE,2EAA0E;AAa1E,SAAgB,SAAS,CAAI,KAAyB,EAAE,SAAwB;IAC9E,IAAI,KAAK,IAAI,IAAI,EAAE;QACjB,IAAI,yCAAmB,CAAC,KAAK,CAAC,EAAE;YAC9B,OAAO,uCAAkB,CAAC,KAAK,EAAE,SAAS,CAAC,CAAC;SAC7C;QACD,IAAI,yBAAW,CAAC,KAAK,CAAC,EAAE;YACtB,OAAO,6BAAa,CAAC,KAAK,EAAE,SAAS,CAAC,CAAC;SACxC;QACD,IAAI,qBAAS,CAAC,KAAK,CAAC,EAAE;YACpB,OAAO,iCAAe,CAAC,KAAK,EAAE,SAAS,CAAC,CAAC;SAC1C;QACD,IAAI,iCAAe,CAAC,KAAK,CAAC,EAAE;YAC1B,OAAO,6CAAqB,CAAC,KAAK,EAAE,SAAS,CAAC,CAAC;SAChD;QACD,IAAI,uBAAU,CAAC,KAAK,CAAC,EAAE;YACrB,OAAO,mCAAgB,CAAC,KAAK,EAAE,SAAS,CAAC,CAAC;SAC3C;QACD,IAAI,2CAAoB,CAAC,KAAK,CAAC,EAAE;YAC/B,OAAO,uDAA0B,CAAC,KAAK,EAAE,SAAS,CAAC,CAAC;SACrD;KACF;IACD,MAAM,yDAAgC,CAAC,KAAK,CAAC,CAAC;AAChD,CAAC;AAtBD,8BAsBC"} \ No newline at end of file
send patches to the email below
yukais@pinapelz.com
include the subject [PATCH repo_name]
pinapelz.com
homepage