From e4fa1e69e7ebfb627c7198fd1a9881e9327ec4d4 Mon Sep 17 00:00:00 2001 From: Pinapelz Date: Sat, 28 Jun 2025 17:26:46 -0700 Subject: initial commit: scaffolding --- .../rxjs/dist/esm/internal/observable/generate.js | 38 ++++++++++++++++++++++ 1 file changed, 38 insertions(+) create mode 100644 node_modules/rxjs/dist/esm/internal/observable/generate.js (limited to 'node_modules/rxjs/dist/esm/internal/observable/generate.js') diff --git a/node_modules/rxjs/dist/esm/internal/observable/generate.js b/node_modules/rxjs/dist/esm/internal/observable/generate.js new file mode 100644 index 0000000..4d709c7 --- /dev/null +++ b/node_modules/rxjs/dist/esm/internal/observable/generate.js @@ -0,0 +1,38 @@ +import { identity } from '../util/identity'; +import { isScheduler } from '../util/isScheduler'; +import { defer } from './defer'; +import { scheduleIterable } from '../scheduled/scheduleIterable'; +export function generate(initialStateOrOptions, condition, iterate, resultSelectorOrScheduler, scheduler) { + let resultSelector; + let initialState; + if (arguments.length === 1) { + ({ + initialState, + condition, + iterate, + resultSelector = identity, + scheduler, + } = initialStateOrOptions); + } + else { + initialState = initialStateOrOptions; + if (!resultSelectorOrScheduler || isScheduler(resultSelectorOrScheduler)) { + resultSelector = identity; + scheduler = resultSelectorOrScheduler; + } + else { + resultSelector = resultSelectorOrScheduler; + } + } + function* gen() { + for (let state = initialState; !condition || condition(state); state = iterate(state)) { + yield resultSelector(state); + } + } + return defer((scheduler + ? + () => scheduleIterable(gen(), scheduler) + : + gen)); +} +//# sourceMappingURL=generate.js.map \ No newline at end of file -- cgit v1.2.3