From 8d52443b55d5138a07167c1f4041d87847e9cf34 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Julien=20Valverd=C3=A9?= <julien.valverde@mailo.com>
Date: Sun, 25 May 2025 03:54:14 +0200
Subject: [PATCH] Fix

---
 packages/extension-query/src/QueryRunner.ts | 11 +++++------
 1 file changed, 5 insertions(+), 6 deletions(-)

diff --git a/packages/extension-query/src/QueryRunner.ts b/packages/extension-query/src/QueryRunner.ts
index c98eacd..4aef061 100644
--- a/packages/extension-query/src/QueryRunner.ts
+++ b/packages/extension-query/src/QueryRunner.ts
@@ -188,11 +188,10 @@ export const run = <K extends readonly unknown[], A, E>(
     if (typeof window !== "undefined" && (options?.refreshOnWindowFocus ?? true))
         yield* Stream.runForEach(BrowserStream.fromEventListenerWindow("focus"), () => self.forkRefresh)
 
-    yield* Effect.addFinalizer(() => self.interrupt).pipe(
-        Effect.andThen(Stream.runForEach(Stream.changes(self.queryKey), latestKey =>
-            Ref.set(self.latestKeyRef, Option.some(latestKey)).pipe(
-                Effect.andThen(self.forkFetch)
-            )
-        ))
+    yield* Effect.addFinalizer(() => self.interrupt)
+    yield* Stream.runForEach(Stream.changes(self.queryKey), latestKey =>
+        Ref.set(self.latestKeyRef, Option.some(latestKey)).pipe(
+            Effect.andThen(self.forkFetch)
+        )
     )
 })