combineLatest.js 855 B

1234567891011121314151617181920
  1. /** PURE_IMPORTS_START _util_isArray,_observable_combineLatest,_observable_from PURE_IMPORTS_END */
  2. import { isArray } from '../util/isArray';
  3. import { CombineLatestOperator } from '../observable/combineLatest';
  4. import { from } from '../observable/from';
  5. var none = {};
  6. export function combineLatest() {
  7. var observables = [];
  8. for (var _i = 0; _i < arguments.length; _i++) {
  9. observables[_i] = arguments[_i];
  10. }
  11. var project = null;
  12. if (typeof observables[observables.length - 1] === 'function') {
  13. project = observables.pop();
  14. }
  15. if (observables.length === 1 && isArray(observables[0])) {
  16. observables = observables[0].slice();
  17. }
  18. return function (source) { return source.lift.call(from([source].concat(observables)), new CombineLatestOperator(project)); };
  19. }
  20. //# sourceMappingURL=combineLatest.js.map