From f85173fa68e01a3568a68fe0bd40e5f3542cd3ab Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Julien=20Valverd=C3=A9?= <julien.valverde@mailo.com>
Date: Tue, 18 Mar 2025 02:46:41 +0100
Subject: [PATCH] Fix

---
 packages/extension-query/src/MutationRunner.ts | 9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

diff --git a/packages/extension-query/src/MutationRunner.ts b/packages/extension-query/src/MutationRunner.ts
index 25334d9..83045c3 100644
--- a/packages/extension-query/src/MutationRunner.ts
+++ b/packages/extension-query/src/MutationRunner.ts
@@ -58,9 +58,12 @@ export const make = <EH, K extends readonly unknown[], A, E, HandledE, R>(
 
     const forkMutate = (...key: K) => Queue.unbounded<AsyncData.AsyncData<A, Exclude<E, HandledE>>>().pipe(
         Effect.flatMap(stateQueue =>
-            run(key, value => Queue.offer(stateQueue, value).pipe(
-                Effect.andThen(Ref.set(stateRef, value))
-            )).pipe(
+            run(
+                key,
+                value => Ref.set(stateRef, value).pipe(
+                    Effect.andThen(Queue.offer(stateQueue, value))
+                ),
+            ).pipe(
                 Effect.tap(() => Queue.shutdown(stateQueue)),
                 Effect.forkDaemon,
                 Effect.map(fiber => [fiber, Stream.fromQueue(stateQueue)] as const)