diff options
| author | Pinapelz <yukais@pinapelz.com> | 2025-06-29 11:49:28 -0700 |
|---|---|---|
| committer | Pinapelz <yukais@pinapelz.com> | 2025-06-29 11:49:28 -0700 |
| commit | d55b767039605256c736166a942a9138e3eacfd7 (patch) | |
| tree | 947063b634c50d438a794325f13275e134aa5993 /node_modules/rxjs/dist/cjs/internal/scheduled | |
| parent | 864ce67d89c77d8ef9c3361f80d619853abcf91c (diff) | |
remove dev node_modules (oops)
Diffstat (limited to 'node_modules/rxjs/dist/cjs/internal/scheduled')
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 |
