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 = <EH, K extends readonly unknown[], A, E, HandledE, R>(
     )
 
     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)
             )