improve

unnoq · unnoq · commit 6110cb1ba2c4 · 2025-08-23T19:58:32.000+07:00
diff --git a/packages/shared/src/iterator.ts b/packages/shared/src/iterator.ts
@@ -157,7 +157,7 @@ export function replicateAsyncIterator<T, TReturn, TNext>(
         queue.close({ id })
 
         if (reason !== 'next') {
-          if (replicated.every((_, id) => !queue.isOpen(id.toString()))) {
+          if (!queue.length) {
             await source?.return?.()
           }
         }

Original file line number	Diff line number	Diff line change
`@@ -157,7 +157,7 @@ export function replicateAsyncIterator<T, TReturn, TNext>(`
`157`	`157`	`queue.close({ id })`
`158`	`158`
`159`	`159`	`if (reason !== 'next') {`
`160`		`- if (replicated.every((_, id) => !queue.isOpen(id.toString()))) {`
	`160`	`+ if (!queue.length) {`
`161`	`161`	`await source?.return?.()`
`162`	`162`	`}`
`163`	`163`	`}`