Update merge.ts

ReactiveX · Apr 25, 2023 · 1833c2a · 1833c2a
1 parent b26982a
commit 1833c2a
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/asynciterable/merge.ts b/src/asynciterable/merge.ts
@@ -42,8 +42,10 @@ 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$;
-        nexts[index] = wrapPromiseWithIndex(iterators[index].next(), index);
+        nexts[index] = wrapPromiseWithIndex(iterator$.next(), index);
       }
     }
   }