fix: two rune bugs (#1160)

paritytech · Jul 14, 2023 · 58a2c64 · 58a2c64
1 parent 96683bf
commit 58a2c64
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/rune/Rune.ts b/rune/Rune.ts
@@ -87,9 +87,9 @@ export class Rune<out T, out U = never> {
   }
 
   async *iter(runner: Runner = globalRunner) {
+    let time = runner.timeline.current
     const primed = runner.prime(this)
     primed.reference()
-    let time = runner.timeline.current
     try {
       while (time !== Infinity) {
         const receipt = new Receipt()
@@ -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()