aboutsummaryrefslogtreecommitdiffstats
path: root/node_modules/rxjs/dist/esm5/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/esm5/internal/scheduled
parent864ce67d89c77d8ef9c3361f80d619853abcf91c (diff)
remove dev node_modules (oops)
Diffstat (limited to 'node_modules/rxjs/dist/esm5/internal/scheduled')
-rw-r--r--node_modules/rxjs/dist/esm5/internal/scheduled/scheduleArray.js18
-rw-r--r--node_modules/rxjs/dist/esm5/internal/scheduled/scheduleArray.js.map1
-rw-r--r--node_modules/rxjs/dist/esm5/internal/scheduled/scheduleAsyncIterable.js23
-rw-r--r--node_modules/rxjs/dist/esm5/internal/scheduled/scheduleAsyncIterable.js.map1
-rw-r--r--node_modules/rxjs/dist/esm5/internal/scheduled/scheduleIterable.js32
-rw-r--r--node_modules/rxjs/dist/esm5/internal/scheduled/scheduleIterable.js.map1
-rw-r--r--node_modules/rxjs/dist/esm5/internal/scheduled/scheduleObservable.js7
-rw-r--r--node_modules/rxjs/dist/esm5/internal/scheduled/scheduleObservable.js.map1
-rw-r--r--node_modules/rxjs/dist/esm5/internal/scheduled/schedulePromise.js7
-rw-r--r--node_modules/rxjs/dist/esm5/internal/scheduled/schedulePromise.js.map1
-rw-r--r--node_modules/rxjs/dist/esm5/internal/scheduled/scheduleReadableStreamLike.js6
-rw-r--r--node_modules/rxjs/dist/esm5/internal/scheduled/scheduleReadableStreamLike.js.map1
-rw-r--r--node_modules/rxjs/dist/esm5/internal/scheduled/scheduled.js37
-rw-r--r--node_modules/rxjs/dist/esm5/internal/scheduled/scheduled.js.map1
14 files changed, 0 insertions, 137 deletions
diff --git a/node_modules/rxjs/dist/esm5/internal/scheduled/scheduleArray.js b/node_modules/rxjs/dist/esm5/internal/scheduled/scheduleArray.js
deleted file mode 100644
index a409116..0000000
--- a/node_modules/rxjs/dist/esm5/internal/scheduled/scheduleArray.js
+++ /dev/null
@@ -1,18 +0,0 @@
-import { Observable } from '../Observable';
-export function scheduleArray(input, scheduler) {
- return new 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();
- }
- }
- });
- });
-}
-//# sourceMappingURL=scheduleArray.js.map \ No newline at end of file
diff --git a/node_modules/rxjs/dist/esm5/internal/scheduled/scheduleArray.js.map b/node_modules/rxjs/dist/esm5/internal/scheduled/scheduleArray.js.map
deleted file mode 100644
index e1e42e7..0000000
--- a/node_modules/rxjs/dist/esm5/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,OAAO,EAAE,UAAU,EAAE,MAAM,eAAe,CAAC;AAG3C,MAAM,UAAU,aAAa,CAAI,KAAmB,EAAE,SAAwB;IAC5E,OAAO,IAAI,UAAU,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"} \ No newline at end of file
diff --git a/node_modules/rxjs/dist/esm5/internal/scheduled/scheduleAsyncIterable.js b/node_modules/rxjs/dist/esm5/internal/scheduled/scheduleAsyncIterable.js
deleted file mode 100644
index c5d5e21..0000000
--- a/node_modules/rxjs/dist/esm5/internal/scheduled/scheduleAsyncIterable.js
+++ /dev/null
@@ -1,23 +0,0 @@
-import { Observable } from '../Observable';
-import { executeSchedule } from '../util/executeSchedule';
-export function scheduleAsyncIterable(input, scheduler) {
- if (!input) {
- throw new Error('Iterable cannot be null');
- }
- return new Observable(function (subscriber) {
- executeSchedule(subscriber, scheduler, function () {
- var iterator = input[Symbol.asyncIterator]();
- executeSchedule(subscriber, scheduler, function () {
- iterator.next().then(function (result) {
- if (result.done) {
- subscriber.complete();
- }
- else {
- subscriber.next(result.value);
- }
- });
- }, 0, true);
- });
- });
-}
-//# sourceMappingURL=scheduleAsyncIterable.js.map \ No newline at end of file
diff --git a/node_modules/rxjs/dist/esm5/internal/scheduled/scheduleAsyncIterable.js.map b/node_modules/rxjs/dist/esm5/internal/scheduled/scheduleAsyncIterable.js.map
deleted file mode 100644
index 0b0413e..0000000
--- a/node_modules/rxjs/dist/esm5/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,OAAO,EAAE,UAAU,EAAE,MAAM,eAAe,CAAC;AAC3C,OAAO,EAAE,eAAe,EAAE,MAAM,yBAAyB,CAAC;AAE1D,MAAM,UAAU,qBAAqB,CAAI,KAAuB,EAAE,SAAwB;IACxF,IAAI,CAAC,KAAK,EAAE;QACV,MAAM,IAAI,KAAK,CAAC,yBAAyB,CAAC,CAAC;KAC5C;IACD,OAAO,IAAI,UAAU,CAAI,UAAC,UAAU;QAClC,eAAe,CAAC,UAAU,EAAE,SAAS,EAAE;YACrC,IAAM,QAAQ,GAAG,KAAK,CAAC,MAAM,CAAC,aAAa,CAAC,EAAE,CAAC;YAC/C,eAAe,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"} \ No newline at end of file
diff --git a/node_modules/rxjs/dist/esm5/internal/scheduled/scheduleIterable.js b/node_modules/rxjs/dist/esm5/internal/scheduled/scheduleIterable.js
deleted file mode 100644
index 20b9345..0000000
--- a/node_modules/rxjs/dist/esm5/internal/scheduled/scheduleIterable.js
+++ /dev/null
@@ -1,32 +0,0 @@
-import { Observable } from '../Observable';
-import { iterator as Symbol_iterator } from '../symbol/iterator';
-import { isFunction } from '../util/isFunction';
-import { executeSchedule } from '../util/executeSchedule';
-export function scheduleIterable(input, scheduler) {
- return new Observable(function (subscriber) {
- var iterator;
- executeSchedule(subscriber, scheduler, function () {
- iterator = input[Symbol_iterator]();
- 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(iterator === null || iterator === void 0 ? void 0 : iterator.return) && iterator.return(); };
- });
-}
-//# sourceMappingURL=scheduleIterable.js.map \ No newline at end of file
diff --git a/node_modules/rxjs/dist/esm5/internal/scheduled/scheduleIterable.js.map b/node_modules/rxjs/dist/esm5/internal/scheduled/scheduleIterable.js.map
deleted file mode 100644
index e970e5b..0000000
--- a/node_modules/rxjs/dist/esm5/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,OAAO,EAAE,UAAU,EAAE,MAAM,eAAe,CAAC;AAE3C,OAAO,EAAE,QAAQ,IAAI,eAAe,EAAE,MAAM,oBAAoB,CAAC;AACjE,OAAO,EAAE,UAAU,EAAE,MAAM,oBAAoB,CAAC;AAChD,OAAO,EAAE,eAAe,EAAE,MAAM,yBAAyB,CAAC;AAO1D,MAAM,UAAU,gBAAgB,CAAI,KAAkB,EAAE,SAAwB;IAC9E,OAAO,IAAI,UAAU,CAAI,UAAC,UAAU;QAClC,IAAI,QAAwB,CAAC;QAK7B,eAAe,CAAC,UAAU,EAAE,SAAS,EAAE;YAErC,QAAQ,GAAI,KAAa,CAAC,eAAe,CAAC,EAAE,CAAC;YAE7C,eAAe,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,UAAU,CAAC,QAAQ,aAAR,QAAQ,uBAAR,QAAQ,CAAE,MAAM,CAAC,IAAI,QAAQ,CAAC,MAAM,EAAE,EAAjD,CAAiD,CAAC;IACjE,CAAC,CAAC,CAAC;AACL,CAAC"} \ No newline at end of file
diff --git a/node_modules/rxjs/dist/esm5/internal/scheduled/scheduleObservable.js b/node_modules/rxjs/dist/esm5/internal/scheduled/scheduleObservable.js
deleted file mode 100644
index 979b009..0000000
--- a/node_modules/rxjs/dist/esm5/internal/scheduled/scheduleObservable.js
+++ /dev/null
@@ -1,7 +0,0 @@
-import { innerFrom } from '../observable/innerFrom';
-import { observeOn } from '../operators/observeOn';
-import { subscribeOn } from '../operators/subscribeOn';
-export function scheduleObservable(input, scheduler) {
- return innerFrom(input).pipe(subscribeOn(scheduler), observeOn(scheduler));
-}
-//# sourceMappingURL=scheduleObservable.js.map \ No newline at end of file
diff --git a/node_modules/rxjs/dist/esm5/internal/scheduled/scheduleObservable.js.map b/node_modules/rxjs/dist/esm5/internal/scheduled/scheduleObservable.js.map
deleted file mode 100644
index 2010050..0000000
--- a/node_modules/rxjs/dist/esm5/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,OAAO,EAAE,SAAS,EAAE,MAAM,yBAAyB,CAAC;AACpD,OAAO,EAAE,SAAS,EAAE,MAAM,wBAAwB,CAAC;AACnD,OAAO,EAAE,WAAW,EAAE,MAAM,0BAA0B,CAAC;AAGvD,MAAM,UAAU,kBAAkB,CAAI,KAA2B,EAAE,SAAwB;IACzF,OAAO,SAAS,CAAC,KAAK,CAAC,CAAC,IAAI,CAAC,WAAW,CAAC,SAAS,CAAC,EAAE,SAAS,CAAC,SAAS,CAAC,CAAC,CAAC;AAC7E,CAAC"} \ No newline at end of file
diff --git a/node_modules/rxjs/dist/esm5/internal/scheduled/schedulePromise.js b/node_modules/rxjs/dist/esm5/internal/scheduled/schedulePromise.js
deleted file mode 100644
index 287c986..0000000
--- a/node_modules/rxjs/dist/esm5/internal/scheduled/schedulePromise.js
+++ /dev/null
@@ -1,7 +0,0 @@
-import { innerFrom } from '../observable/innerFrom';
-import { observeOn } from '../operators/observeOn';
-import { subscribeOn } from '../operators/subscribeOn';
-export function schedulePromise(input, scheduler) {
- return innerFrom(input).pipe(subscribeOn(scheduler), observeOn(scheduler));
-}
-//# sourceMappingURL=schedulePromise.js.map \ No newline at end of file
diff --git a/node_modules/rxjs/dist/esm5/internal/scheduled/schedulePromise.js.map b/node_modules/rxjs/dist/esm5/internal/scheduled/schedulePromise.js.map
deleted file mode 100644
index 8da74ad..0000000
--- a/node_modules/rxjs/dist/esm5/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,OAAO,EAAE,SAAS,EAAE,MAAM,yBAAyB,CAAC;AACpD,OAAO,EAAE,SAAS,EAAE,MAAM,wBAAwB,CAAC;AACnD,OAAO,EAAE,WAAW,EAAE,MAAM,0BAA0B,CAAC;AAGvD,MAAM,UAAU,eAAe,CAAI,KAAqB,EAAE,SAAwB;IAChF,OAAO,SAAS,CAAC,KAAK,CAAC,CAAC,IAAI,CAAC,WAAW,CAAC,SAAS,CAAC,EAAE,SAAS,CAAC,SAAS,CAAC,CAAC,CAAC;AAC7E,CAAC"} \ No newline at end of file
diff --git a/node_modules/rxjs/dist/esm5/internal/scheduled/scheduleReadableStreamLike.js b/node_modules/rxjs/dist/esm5/internal/scheduled/scheduleReadableStreamLike.js
deleted file mode 100644
index 4bfbfc2..0000000
--- a/node_modules/rxjs/dist/esm5/internal/scheduled/scheduleReadableStreamLike.js
+++ /dev/null
@@ -1,6 +0,0 @@
-import { scheduleAsyncIterable } from './scheduleAsyncIterable';
-import { readableStreamLikeToAsyncGenerator } from '../util/isReadableStreamLike';
-export function scheduleReadableStreamLike(input, scheduler) {
- return scheduleAsyncIterable(readableStreamLikeToAsyncGenerator(input), scheduler);
-}
-//# sourceMappingURL=scheduleReadableStreamLike.js.map \ No newline at end of file
diff --git a/node_modules/rxjs/dist/esm5/internal/scheduled/scheduleReadableStreamLike.js.map b/node_modules/rxjs/dist/esm5/internal/scheduled/scheduleReadableStreamLike.js.map
deleted file mode 100644
index 6026c90..0000000
--- a/node_modules/rxjs/dist/esm5/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,OAAO,EAAE,qBAAqB,EAAE,MAAM,yBAAyB,CAAC;AAChE,OAAO,EAAE,kCAAkC,EAAE,MAAM,8BAA8B,CAAC;AAElF,MAAM,UAAU,0BAA0B,CAAI,KAA4B,EAAE,SAAwB;IAClG,OAAO,qBAAqB,CAAC,kCAAkC,CAAC,KAAK,CAAC,EAAE,SAAS,CAAC,CAAC;AACrF,CAAC"} \ No newline at end of file
diff --git a/node_modules/rxjs/dist/esm5/internal/scheduled/scheduled.js b/node_modules/rxjs/dist/esm5/internal/scheduled/scheduled.js
deleted file mode 100644
index 3ed1085..0000000
--- a/node_modules/rxjs/dist/esm5/internal/scheduled/scheduled.js
+++ /dev/null
@@ -1,37 +0,0 @@
-import { scheduleObservable } from './scheduleObservable';
-import { schedulePromise } from './schedulePromise';
-import { scheduleArray } from './scheduleArray';
-import { scheduleIterable } from './scheduleIterable';
-import { scheduleAsyncIterable } from './scheduleAsyncIterable';
-import { isInteropObservable } from '../util/isInteropObservable';
-import { isPromise } from '../util/isPromise';
-import { isArrayLike } from '../util/isArrayLike';
-import { isIterable } from '../util/isIterable';
-import { isAsyncIterable } from '../util/isAsyncIterable';
-import { createInvalidObservableTypeError } from '../util/throwUnobservableError';
-import { isReadableStreamLike } from '../util/isReadableStreamLike';
-import { scheduleReadableStreamLike } from './scheduleReadableStreamLike';
-export function scheduled(input, scheduler) {
- if (input != null) {
- if (isInteropObservable(input)) {
- return scheduleObservable(input, scheduler);
- }
- if (isArrayLike(input)) {
- return scheduleArray(input, scheduler);
- }
- if (isPromise(input)) {
- return schedulePromise(input, scheduler);
- }
- if (isAsyncIterable(input)) {
- return scheduleAsyncIterable(input, scheduler);
- }
- if (isIterable(input)) {
- return scheduleIterable(input, scheduler);
- }
- if (isReadableStreamLike(input)) {
- return scheduleReadableStreamLike(input, scheduler);
- }
- }
- throw createInvalidObservableTypeError(input);
-}
-//# sourceMappingURL=scheduled.js.map \ No newline at end of file
diff --git a/node_modules/rxjs/dist/esm5/internal/scheduled/scheduled.js.map b/node_modules/rxjs/dist/esm5/internal/scheduled/scheduled.js.map
deleted file mode 100644
index 6355931..0000000
--- a/node_modules/rxjs/dist/esm5/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,OAAO,EAAE,kBAAkB,EAAE,MAAM,sBAAsB,CAAC;AAC1D,OAAO,EAAE,eAAe,EAAE,MAAM,mBAAmB,CAAC;AACpD,OAAO,EAAE,aAAa,EAAE,MAAM,iBAAiB,CAAC;AAChD,OAAO,EAAE,gBAAgB,EAAE,MAAM,oBAAoB,CAAC;AACtD,OAAO,EAAE,qBAAqB,EAAE,MAAM,yBAAyB,CAAC;AAChE,OAAO,EAAE,mBAAmB,EAAE,MAAM,6BAA6B,CAAC;AAClE,OAAO,EAAE,SAAS,EAAE,MAAM,mBAAmB,CAAC;AAC9C,OAAO,EAAE,WAAW,EAAE,MAAM,qBAAqB,CAAC;AAClD,OAAO,EAAE,UAAU,EAAE,MAAM,oBAAoB,CAAC;AAGhD,OAAO,EAAE,eAAe,EAAE,MAAM,yBAAyB,CAAC;AAC1D,OAAO,EAAE,gCAAgC,EAAE,MAAM,gCAAgC,CAAC;AAClF,OAAO,EAAE,oBAAoB,EAAE,MAAM,8BAA8B,CAAC;AACpE,OAAO,EAAE,0BAA0B,EAAE,MAAM,8BAA8B,CAAC;AAa1E,MAAM,UAAU,SAAS,CAAI,KAAyB,EAAE,SAAwB;IAC9E,IAAI,KAAK,IAAI,IAAI,EAAE;QACjB,IAAI,mBAAmB,CAAC,KAAK,CAAC,EAAE;YAC9B,OAAO,kBAAkB,CAAC,KAAK,EAAE,SAAS,CAAC,CAAC;SAC7C;QACD,IAAI,WAAW,CAAC,KAAK,CAAC,EAAE;YACtB,OAAO,aAAa,CAAC,KAAK,EAAE,SAAS,CAAC,CAAC;SACxC;QACD,IAAI,SAAS,CAAC,KAAK,CAAC,EAAE;YACpB,OAAO,eAAe,CAAC,KAAK,EAAE,SAAS,CAAC,CAAC;SAC1C;QACD,IAAI,eAAe,CAAC,KAAK,CAAC,EAAE;YAC1B,OAAO,qBAAqB,CAAC,KAAK,EAAE,SAAS,CAAC,CAAC;SAChD;QACD,IAAI,UAAU,CAAC,KAAK,CAAC,EAAE;YACrB,OAAO,gBAAgB,CAAC,KAAK,EAAE,SAAS,CAAC,CAAC;SAC3C;QACD,IAAI,oBAAoB,CAAC,KAAK,CAAC,EAAE;YAC/B,OAAO,0BAA0B,CAAC,KAAK,EAAE,SAAS,CAAC,CAAC;SACrD;KACF;IACD,MAAM,gCAAgC,CAAC,KAAK,CAAC,CAAC;AAChD,CAAC"} \ No newline at end of file
send patches to the email below
yukais@pinapelz.com
include the subject [PATCH repo_name]
pinapelz.com
homepage