123456789101112131415 |
- 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(...args) {
- const resultSelector = popResultSelector(args);
- return resultSelector
- ? pipe(combineLatest(...args), mapOneOrManyArgs(resultSelector))
- : operate((source, subscriber) => {
- combineLatestInit([source, ...argsOrArgArray(args)])(subscriber);
- });
- }
- //# sourceMappingURL=combineLatest.js.map
|