From e4fa1e69e7ebfb627c7198fd1a9881e9327ec4d4 Mon Sep 17 00:00:00 2001 From: Pinapelz Date: Sat, 28 Jun 2025 17:26:46 -0700 Subject: initial commit: scaffolding --- .../dist/esm5/internal/operators/withLatestFrom.js | 39 ++++++++++++++++++++++ 1 file changed, 39 insertions(+) create mode 100644 node_modules/rxjs/dist/esm5/internal/operators/withLatestFrom.js (limited to 'node_modules/rxjs/dist/esm5/internal/operators/withLatestFrom.js') diff --git a/node_modules/rxjs/dist/esm5/internal/operators/withLatestFrom.js b/node_modules/rxjs/dist/esm5/internal/operators/withLatestFrom.js new file mode 100644 index 0000000..6240899 --- /dev/null +++ b/node_modules/rxjs/dist/esm5/internal/operators/withLatestFrom.js @@ -0,0 +1,39 @@ +import { __read, __spreadArray } from "tslib"; +import { operate } from '../util/lift'; +import { createOperatorSubscriber } from './OperatorSubscriber'; +import { innerFrom } from '../observable/innerFrom'; +import { identity } from '../util/identity'; +import { noop } from '../util/noop'; +import { popResultSelector } from '../util/args'; +export function withLatestFrom() { + var inputs = []; + for (var _i = 0; _i < arguments.length; _i++) { + inputs[_i] = arguments[_i]; + } + var project = popResultSelector(inputs); + return operate(function (source, subscriber) { + var len = inputs.length; + var otherValues = new Array(len); + var hasValue = inputs.map(function () { return false; }); + var ready = false; + var _loop_1 = function (i) { + innerFrom(inputs[i]).subscribe(createOperatorSubscriber(subscriber, function (value) { + otherValues[i] = value; + if (!ready && !hasValue[i]) { + hasValue[i] = true; + (ready = hasValue.every(identity)) && (hasValue = null); + } + }, noop)); + }; + for (var i = 0; i < len; i++) { + _loop_1(i); + } + source.subscribe(createOperatorSubscriber(subscriber, function (value) { + if (ready) { + var values = __spreadArray([value], __read(otherValues)); + subscriber.next(project ? project.apply(void 0, __spreadArray([], __read(values))) : values); + } + })); + }); +} +//# sourceMappingURL=withLatestFrom.js.map \ No newline at end of file -- cgit v1.2.3