Cleanup

packages/example/src/routes/query/service.tsx

@@ -22,9 +22,9 @@ function RouteComponent() {
 
     const query = R.useQuery({
         key: R.useStreamFromValues(["uuid4", 10]),
-        query: () => Console.log(`Querying 10 IDs...`).pipe(
+        query: ([, count]) => Console.log(`Querying ${ count } IDs...`).pipe(
             Effect.andThen(Effect.sleep("500 millis")),
-            Effect.andThen(HttpClient.get(`https://www.uuidtools.com/api/generate/v4/count/10`)),
+            Effect.andThen(HttpClient.get(`https://www.uuidtools.com/api/generate/v4/count/${ count }`)),
             HttpClient.withTracerPropagation(false),
             Effect.flatMap(res => res.json),
             Effect.flatMap(Schema.decodeUnknown(Uuid4Query.Result)),

packages/extension-query/src/QueryExtension.ts

@@ -31,14 +31,6 @@ export const QueryExtension = ReffuseExtension.make(() => ({
             query: props.query,
         }), [props.key])
 
-        // this.useFork(() => Effect.addFinalizer(() => runner.forkInterrupt).pipe(
-        //     Effect.andThen(Stream.runForEach(runner.key, () =>
-        //         Ref.set(runner.queryRef, props.query()).pipe(
-        //             Effect.andThen(runner.forkFetch)
-        //         )
-        //     ))
-        // ), [runner])
-
         this.useFork(() => runner.fetchOnKeyChange, [runner])
 
         this.useFork(() => (props.refreshOnWindowFocus ?? true)