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/cjs/internal/operators/raceWith.js | 40 ++++++++++++++++++++++ 1 file changed, 40 insertions(+) create mode 100644 node_modules/rxjs/dist/cjs/internal/operators/raceWith.js (limited to 'node_modules/rxjs/dist/cjs/internal/operators/raceWith.js') diff --git a/node_modules/rxjs/dist/cjs/internal/operators/raceWith.js b/node_modules/rxjs/dist/cjs/internal/operators/raceWith.js new file mode 100644 index 0000000..a29805d --- /dev/null +++ b/node_modules/rxjs/dist/cjs/internal/operators/raceWith.js @@ -0,0 +1,40 @@ +"use strict"; +var __read = (this && this.__read) || function (o, n) { + var m = typeof Symbol === "function" && o[Symbol.iterator]; + if (!m) return o; + var i = m.call(o), r, ar = [], e; + try { + while ((n === void 0 || n-- > 0) && !(r = i.next()).done) ar.push(r.value); + } + catch (error) { e = { error: error }; } + finally { + try { + if (r && !r.done && (m = i["return"])) m.call(i); + } + finally { if (e) throw e.error; } + } + return ar; +}; +var __spreadArray = (this && this.__spreadArray) || function (to, from) { + for (var i = 0, il = from.length, j = to.length; i < il; i++, j++) + to[j] = from[i]; + return to; +}; +Object.defineProperty(exports, "__esModule", { value: true }); +exports.raceWith = void 0; +var race_1 = require("../observable/race"); +var lift_1 = require("../util/lift"); +var identity_1 = require("../util/identity"); +function raceWith() { + var otherSources = []; + for (var _i = 0; _i < arguments.length; _i++) { + otherSources[_i] = arguments[_i]; + } + return !otherSources.length + ? identity_1.identity + : lift_1.operate(function (source, subscriber) { + race_1.raceInit(__spreadArray([source], __read(otherSources)))(subscriber); + }); +} +exports.raceWith = raceWith; +//# sourceMappingURL=raceWith.js.map \ No newline at end of file -- cgit v1.2.3