race.js 625 B

12345678910111213141516
  1. /** PURE_IMPORTS_START _util_isArray,_observable_race PURE_IMPORTS_END */
  2. import { isArray } from '../util/isArray';
  3. import { race as raceStatic } from '../observable/race';
  4. export function race() {
  5. var observables = [];
  6. for (var _i = 0; _i < arguments.length; _i++) {
  7. observables[_i] = arguments[_i];
  8. }
  9. return function raceOperatorFunction(source) {
  10. if (observables.length === 1 && isArray(observables[0])) {
  11. observables = observables[0];
  12. }
  13. return source.lift.call(raceStatic.apply(void 0, [source].concat(observables)));
  14. };
  15. }
  16. //# sourceMappingURL=race.js.map