fix(forkJoin): Fix concurrent sort order.

cartant · Feb 21, 2018 · b34ffcc · b34ffcc
1 parent 68667aa
commit b34ffcc
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/source/observable/forkJoinConcurrent.ts b/source/observable/forkJoinConcurrent.ts
@@ -18,6 +18,6 @@ export function forkJoinConcurrent<T>(
     return from(observables).pipe(
         mergeMap(o => o.pipe(last()), (ov, iv, oi, ii) => ({ index: oi, value: iv }), concurrent),
         toArray(),
-        map(a => a.sort((l, r) => r.index - l.index).map(e => e.value))
+        map(a => a.sort((l, r) => l.index - r.index).map(e => e.value))
     );
 }