From fd3213c53f759fd754c34b5add90cf7493a6a507 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Julien=20Valverd=C3=A9?= <julien.valverde@mailo.com>
Date: Mon, 24 Mar 2025 12:06:03 +0100
Subject: [PATCH] Fix

---
 packages/extension-query/src/internal/QueryRunner.ts | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/packages/extension-query/src/internal/QueryRunner.ts b/packages/extension-query/src/internal/QueryRunner.ts
index 15148bc..cbf52e9 100644
--- a/packages/extension-query/src/internal/QueryRunner.ts
+++ b/packages/extension-query/src/internal/QueryRunner.ts
@@ -109,6 +109,7 @@ export const make = <EH, K extends readonly unknown[], A, E, HandledE, R>(
                 Effect.andThen(state.set(AsyncData.loading()).pipe(
                     Effect.andThen(run),
                     Effect.tap(() => Ref.set(fiberRef, Option.none())),
+                    Effect.tap(() => Queue.shutdown(stateQueue)),
                     Effect.forkDaemon,
                 )),
 
@@ -141,6 +142,7 @@ export const make = <EH, K extends readonly unknown[], A, E, HandledE, R>(
             Effect.andThen(setInitialRefreshState.pipe(
                 Effect.andThen(run),
                 Effect.tap(() => Ref.set(fiberRef, Option.none())),
+                Effect.tap(() => Queue.shutdown(stateQueue)),
                 Effect.forkDaemon,
             )),