fix 1147

paritytech · Jul 11, 2023 · 100d652 · 100d652
1 parent 4859e5e
commit 100d652
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/rune/Rune.ts b/rune/Rune.ts
@@ -366,6 +366,7 @@ class RunAsyncIter<T> extends RunStream<T> {
     super(runner)
     ;(async () => {
       for await (const value of fn()) {
+        if (!this.alive) break
         this.push(value)
       }
       this.finish()