diff options
Diffstat (limited to 'node_modules/rxjs/dist/esm/internal/scheduled')
14 files changed, 136 insertions, 0 deletions
diff --git a/node_modules/rxjs/dist/esm/internal/scheduled/scheduleArray.js b/node_modules/rxjs/dist/esm/internal/scheduled/scheduleArray.js new file mode 100644 index 0000000..ea7b5cb --- /dev/null +++ b/node_modules/rxjs/dist/esm/internal/scheduled/scheduleArray.js @@ -0,0 +1,18 @@ +import { Observable } from '../Observable'; +export function scheduleArray(input, scheduler) { + return new Observable((subscriber) => { + let 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/esm/internal/scheduled/scheduleArray.js.map b/node_modules/rxjs/dist/esm/internal/scheduled/scheduleArray.js.map new file mode 100644 index 0000000..b14139b --- /dev/null +++ b/node_modules/rxjs/dist/esm/internal/scheduled/scheduleArray.js.map @@ -0,0 +1 @@ +{"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,CAAC,UAAU,EAAE,EAAE;QAEtC,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/esm/internal/scheduled/scheduleAsyncIterable.js b/node_modules/rxjs/dist/esm/internal/scheduled/scheduleAsyncIterable.js new file mode 100644 index 0000000..2ab8199 --- /dev/null +++ b/node_modules/rxjs/dist/esm/internal/scheduled/scheduleAsyncIterable.js @@ -0,0 +1,23 @@ +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((subscriber) => { + executeSchedule(subscriber, scheduler, () => { + const iterator = input[Symbol.asyncIterator](); + executeSchedule(subscriber, scheduler, () => { + iterator.next().then((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/esm/internal/scheduled/scheduleAsyncIterable.js.map b/node_modules/rxjs/dist/esm/internal/scheduled/scheduleAsyncIterable.js.map new file mode 100644 index 0000000..80005cd --- /dev/null +++ b/node_modules/rxjs/dist/esm/internal/scheduled/scheduleAsyncIterable.js.map @@ -0,0 +1 @@ +{"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,CAAC,UAAU,EAAE,EAAE;QACtC,eAAe,CAAC,UAAU,EAAE,SAAS,EAAE,GAAG,EAAE;YAC1C,MAAM,QAAQ,GAAG,KAAK,CAAC,MAAM,CAAC,aAAa,CAAC,EAAE,CAAC;YAC/C,eAAe,CACb,UAAU,EACV,SAAS,EACT,GAAG,EAAE;gBACH,QAAQ,CAAC,IAAI,EAAE,CAAC,IAAI,CAAC,CAAC,MAAM,EAAE,EAAE;oBAC9B,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/esm/internal/scheduled/scheduleIterable.js b/node_modules/rxjs/dist/esm/internal/scheduled/scheduleIterable.js new file mode 100644 index 0000000..c4f6236 --- /dev/null +++ b/node_modules/rxjs/dist/esm/internal/scheduled/scheduleIterable.js @@ -0,0 +1,31 @@ +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((subscriber) => { + let iterator; + executeSchedule(subscriber, scheduler, () => { + iterator = input[Symbol_iterator](); + executeSchedule(subscriber, scheduler, () => { + let value; + let done; + try { + ({ value, done } = iterator.next()); + } + catch (err) { + subscriber.error(err); + return; + } + if (done) { + subscriber.complete(); + } + else { + subscriber.next(value); + } + }, 0, true); + }); + 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/esm/internal/scheduled/scheduleIterable.js.map b/node_modules/rxjs/dist/esm/internal/scheduled/scheduleIterable.js.map new file mode 100644 index 0000000..16ebd84 --- /dev/null +++ b/node_modules/rxjs/dist/esm/internal/scheduled/scheduleIterable.js.map @@ -0,0 +1 @@ +{"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,CAAC,UAAU,EAAE,EAAE;QACtC,IAAI,QAAwB,CAAC;QAK7B,eAAe,CAAC,UAAU,EAAE,SAAS,EAAE,GAAG,EAAE;YAE1C,QAAQ,GAAI,KAAa,CAAC,eAAe,CAAC,EAAE,CAAC;YAE7C,eAAe,CACb,UAAU,EACV,SAAS,EACT,GAAG,EAAE;gBACH,IAAI,KAAQ,CAAC;gBACb,IAAI,IAAyB,CAAC;gBAC9B,IAAI;oBAEF,CAAC,EAAE,KAAK,EAAE,IAAI,EAAE,GAAG,QAAQ,CAAC,IAAI,EAAE,CAAC,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,GAAG,EAAE,CAAC,UAAU,CAAC,QAAQ,aAAR,QAAQ,uBAAR,QAAQ,CAAE,MAAM,CAAC,IAAI,QAAQ,CAAC,MAAM,EAAE,CAAC;IACjE,CAAC,CAAC,CAAC;AACL,CAAC"}
\ No newline at end of file diff --git a/node_modules/rxjs/dist/esm/internal/scheduled/scheduleObservable.js b/node_modules/rxjs/dist/esm/internal/scheduled/scheduleObservable.js new file mode 100644 index 0000000..979b009 --- /dev/null +++ b/node_modules/rxjs/dist/esm/internal/scheduled/scheduleObservable.js @@ -0,0 +1,7 @@ +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/esm/internal/scheduled/scheduleObservable.js.map b/node_modules/rxjs/dist/esm/internal/scheduled/scheduleObservable.js.map new file mode 100644 index 0000000..2010050 --- /dev/null +++ b/node_modules/rxjs/dist/esm/internal/scheduled/scheduleObservable.js.map @@ -0,0 +1 @@ +{"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/esm/internal/scheduled/schedulePromise.js b/node_modules/rxjs/dist/esm/internal/scheduled/schedulePromise.js new file mode 100644 index 0000000..287c986 --- /dev/null +++ b/node_modules/rxjs/dist/esm/internal/scheduled/schedulePromise.js @@ -0,0 +1,7 @@ +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/esm/internal/scheduled/schedulePromise.js.map b/node_modules/rxjs/dist/esm/internal/scheduled/schedulePromise.js.map new file mode 100644 index 0000000..8da74ad --- /dev/null +++ b/node_modules/rxjs/dist/esm/internal/scheduled/schedulePromise.js.map @@ -0,0 +1 @@ +{"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/esm/internal/scheduled/scheduleReadableStreamLike.js b/node_modules/rxjs/dist/esm/internal/scheduled/scheduleReadableStreamLike.js new file mode 100644 index 0000000..4bfbfc2 --- /dev/null +++ b/node_modules/rxjs/dist/esm/internal/scheduled/scheduleReadableStreamLike.js @@ -0,0 +1,6 @@ +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/esm/internal/scheduled/scheduleReadableStreamLike.js.map b/node_modules/rxjs/dist/esm/internal/scheduled/scheduleReadableStreamLike.js.map new file mode 100644 index 0000000..6026c90 --- /dev/null +++ b/node_modules/rxjs/dist/esm/internal/scheduled/scheduleReadableStreamLike.js.map @@ -0,0 +1 @@ +{"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/esm/internal/scheduled/scheduled.js b/node_modules/rxjs/dist/esm/internal/scheduled/scheduled.js new file mode 100644 index 0000000..3ed1085 --- /dev/null +++ b/node_modules/rxjs/dist/esm/internal/scheduled/scheduled.js @@ -0,0 +1,37 @@ +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/esm/internal/scheduled/scheduled.js.map b/node_modules/rxjs/dist/esm/internal/scheduled/scheduled.js.map new file mode 100644 index 0000000..6355931 --- /dev/null +++ b/node_modules/rxjs/dist/esm/internal/scheduled/scheduled.js.map @@ -0,0 +1 @@ +{"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 |