combineLatest.js 536 B

12345678910111213
  1. import { of } from 'rxjs';
  2. import { isArray, CombineLatestOperator } from 'rxjs/internal-compatibility';
  3. export function combineLatest(...observables) {
  4. let project = null;
  5. if (typeof observables[observables.length - 1] === 'function') {
  6. project = observables.pop();
  7. }
  8. if (observables.length === 1 && isArray(observables[0])) {
  9. observables = observables[0].slice();
  10. }
  11. return this.lift.call(of(this, ...observables), new CombineLatestOperator(project));
  12. }
  13. //# sourceMappingURL=combineLatest.js.map