Query work

2025-03-03 19:42:33 +01:00
parent 9c96741c8e
commit 40e8bf6a1f
3 changed files with 15 additions and 7 deletions
--- a/packages/extension-query/src/index.ts
+++ b/packages/extension-query/src/index.ts
@@ -25,7 +25,7 @@ export const QueryExtension = ReffuseExtension.make(() => ({

        this.useFork(() => Stream.runForEach(runner.fiberRef.changes, Console.log), [])

-        this.useFork(() => Effect.addFinalizer(() => runner.interrupt).pipe(
+        this.useEffect(() => Effect.addFinalizer(() => Effect.void).pipe(
            Effect.andThen(Ref.set(runner.queryRef, props.effect())),
            Effect.andThen(runner.forkFetch),
        ), [runner, ...props.deps])