forkJoin.js 2.6 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071
  1. /** PURE_IMPORTS_START _Observable,_util_isArray,_operators_map,_util_isObject,_util_isObservable,_from PURE_IMPORTS_END */
  2. import { Observable } from '../Observable';
  3. import { isArray } from '../util/isArray';
  4. import { map } from '../operators/map';
  5. import { isObject } from '../util/isObject';
  6. import { isObservable } from '../util/isObservable';
  7. import { from } from './from';
  8. export function forkJoin() {
  9. var sources = [];
  10. for (var _i = 0; _i < arguments.length; _i++) {
  11. sources[_i] = arguments[_i];
  12. }
  13. if (sources.length === 1) {
  14. var first_1 = sources[0];
  15. if (isArray(first_1)) {
  16. return forkJoinInternal(first_1, null);
  17. }
  18. if (isObject(first_1) && !isObservable(first_1)) {
  19. var keys = Object.keys(first_1);
  20. return forkJoinInternal(keys.map(function (key) { return first_1[key]; }), keys);
  21. }
  22. }
  23. if (typeof sources[sources.length - 1] === 'function') {
  24. var resultSelector_1 = sources.pop();
  25. sources = (sources.length === 1 && isArray(sources[0])) ? sources[0] : sources;
  26. return forkJoinInternal(sources, null).pipe(map(function (args) { return resultSelector_1.apply(void 0, args); }));
  27. }
  28. return forkJoinInternal(sources, null);
  29. }
  30. function forkJoinInternal(sources, keys) {
  31. return new Observable(function (subscriber) {
  32. var len = sources.length;
  33. if (len === 0) {
  34. subscriber.complete();
  35. return;
  36. }
  37. var values = new Array(len);
  38. var completed = 0;
  39. var emitted = 0;
  40. var _loop_1 = function (i) {
  41. var source = from(sources[i]);
  42. var hasValue = false;
  43. subscriber.add(source.subscribe({
  44. next: function (value) {
  45. if (!hasValue) {
  46. hasValue = true;
  47. emitted++;
  48. }
  49. values[i] = value;
  50. },
  51. error: function (err) { return subscriber.error(err); },
  52. complete: function () {
  53. completed++;
  54. if (completed === len || !hasValue) {
  55. if (emitted === len) {
  56. subscriber.next(keys ?
  57. keys.reduce(function (result, key, i) { return (result[key] = values[i], result); }, {}) :
  58. values);
  59. }
  60. subscriber.complete();
  61. }
  62. }
  63. }));
  64. };
  65. for (var i = 0; i < len; i++) {
  66. _loop_1(i);
  67. }
  68. });
  69. }
  70. //# sourceMappingURL=forkJoin.js.map