From 224ccd8e32702c57b652adcaac972f021c23c5f0 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Julien=20Valverd=C3=A9?= Date: Fri, 21 Mar 2025 04:55:38 +0100 Subject: [PATCH] Fix --- packages/extension-query/src/internal/QueryRunner.ts | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/packages/extension-query/src/internal/QueryRunner.ts b/packages/extension-query/src/internal/QueryRunner.ts index a714573..c96ec9d 100644 --- a/packages/extension-query/src/internal/QueryRunner.ts +++ b/packages/extension-query/src/internal/QueryRunner.ts @@ -133,7 +133,7 @@ export const make = ( ) const fetchOnKeyChange = Effect.addFinalizer(() => interrupt).pipe( - Effect.andThen(Stream.runForEach(key, latestKey => + Effect.andThen(Stream.runForEach(Stream.changes(key), latestKey => Ref.set(latestKeyRef, Option.some(latestKey)).pipe( Effect.andThen(forkFetch) )