From fad61afce7e51d72efff1650297c204a5efdcc5a Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Julien=20Valverd=C3=A9?= <julien.valverde@mailo.com>
Date: Thu, 6 Mar 2025 17:32:30 +0100
Subject: [PATCH] Fix

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

diff --git a/packages/extension-query/src/QueryRunner.ts b/packages/extension-query/src/QueryRunner.ts
index e5857bf..f17d226 100644
--- a/packages/extension-query/src/QueryRunner.ts
+++ b/packages/extension-query/src/QueryRunner.ts
@@ -53,7 +53,8 @@ export const make = <A, E, R>(
     const forkFetch = interrupt.pipe(
         Effect.andThen(
             Ref.set(stateRef, AsyncData.loading()).pipe(
-                Effect.andThen(queryRef.pipe(Effect.flatMap(identity))),
+                Effect.andThen(queryRef),
+                Effect.flatMap(identity),
                 Effect.matchCauseEffect({
                     onSuccess: v => Ref.set(stateRef, AsyncData.success(v)),
                     onFailure: c => Ref.set(stateRef, AsyncData.failure(c)),
@@ -83,7 +84,8 @@ export const make = <A, E, R>(
                     return AsyncData.refreshing(previous.previous)
                 return AsyncData.loading()
             }).pipe(
-                Effect.andThen(queryRef.pipe(Effect.flatMap(identity))),
+                Effect.andThen(queryRef),
+                Effect.flatMap(identity),
                 Effect.matchCauseEffect({
                     onSuccess: v => Ref.set(stateRef, AsyncData.success(v)),
                     onFailure: c => Ref.set(stateRef, AsyncData.failure(c)),