diff options
Diffstat (limited to 'node_modules/rxjs/dist/esm5/internal/operators/combineLatest.js')
| -rw-r--r-- | node_modules/rxjs/dist/esm5/internal/operators/combineLatest.js | 20 |
1 files changed, 20 insertions, 0 deletions
diff --git a/node_modules/rxjs/dist/esm5/internal/operators/combineLatest.js b/node_modules/rxjs/dist/esm5/internal/operators/combineLatest.js new file mode 100644 index 0000000..68b4c59 --- /dev/null +++ b/node_modules/rxjs/dist/esm5/internal/operators/combineLatest.js @@ -0,0 +1,20 @@ +import { __read, __spreadArray } from "tslib"; +import { combineLatestInit } from '../observable/combineLatest'; +import { operate } from '../util/lift'; +import { argsOrArgArray } from '../util/argsOrArgArray'; +import { mapOneOrManyArgs } from '../util/mapOneOrManyArgs'; +import { pipe } from '../util/pipe'; +import { popResultSelector } from '../util/args'; +export function combineLatest() { + var args = []; + for (var _i = 0; _i < arguments.length; _i++) { + args[_i] = arguments[_i]; + } + var resultSelector = popResultSelector(args); + return resultSelector + ? pipe(combineLatest.apply(void 0, __spreadArray([], __read(args))), mapOneOrManyArgs(resultSelector)) + : operate(function (source, subscriber) { + combineLatestInit(__spreadArray([source], __read(argsOrArgArray(args))))(subscriber); + }); +} +//# sourceMappingURL=combineLatest.js.map
\ No newline at end of file |
