Update merge.ts

ReactiveX · Dec 27, 2023 · 51243ce · 51243ce
1 parent 8f1cafd
commit 51243ce
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/src/asynciterable/merge.ts b/src/asynciterable/merge.ts
@@ -42,9 +42,8 @@ export class MergeAsyncIterable<T> extends AsyncIterableX<T> {
         nexts[index] = <Promise<MergeResult<IteratorResult<T>>>>NEVER_PROMISE;
         active--;
       } else {
-        const iterator$ = iterators[index];
-        nexts[index] = <Promise<MergeResult<IteratorResult<T>>>>NEVER_PROMISE;
         yield value$;
+        const iterator$ = iterators[index];
         nexts[index] = wrapPromiseWithIndex(iterator$.next(), index);
       }
     }