Query work

packages/extension-query/src/QueryExtension.ts

@@ -12,11 +12,13 @@ export interface UseQueryProps<K extends readonly unknown[], A, E, R> {
     readonly refreshOnWindowFocus?: boolean
 }
 
-export interface UseQueryResult<A, E> {
+export interface UseQueryResult<K extends readonly unknown[], A, E> {
+    readonly keyStream: Stream.Stream<K>
     readonly state: SubscriptionRef.SubscriptionRef<AsyncData.AsyncData<A, E>>
     readonly refresh: Effect.Effect<Fiber.RuntimeFiber<void, Cause.NoSuchElementException>>
+
     readonly layer: <Self, Id extends string>(
-        tag: Context.TagClass<Self, Id, QueryService.QueryService<A, E>>
+        tag: Context.TagClass<Self, Id, QueryService.QueryService<K, A, E>>
     ) => Layer.Layer<Self>
 }
 
@@ -25,7 +27,7 @@ export const QueryExtension = ReffuseExtension.make(() => ({
     useQuery<K extends readonly unknown[], A, E, R>(
         this: ReffuseHelpers.ReffuseHelpers<R>,
         props: UseQueryProps<K, A, E, R>,
-    ): UseQueryResult<A, E> {
+    ): UseQueryResult<K, A, E> {
         const runner = this.useMemo(() => QueryRunner.make({
             key: props.key,
             query: props.query,
@@ -39,10 +41,12 @@ export const QueryExtension = ReffuseExtension.make(() => ({
         [props.refreshOnWindowFocus, runner])
 
         return React.useMemo(() => ({
+            keyStream: props.key,
             state: runner.stateRef,
             refresh: runner.forkRefresh,
 
             layer: tag => Layer.succeed(tag, {
+                keyStream: props.key,
                 state: runner.stateRef,
                 refresh: runner.forkRefresh,
             }),

packages/extension-query/src/QueryService.ts

@@ -1,15 +1,16 @@
 import type * as AsyncData from "@typed/async-data"
-import { type Cause, Effect, type Fiber, type SubscriptionRef } from "effect"
+import { type Cause, Effect, type Fiber, type Stream, type SubscriptionRef } from "effect"
 
 
-export interface QueryService<A, E> {
+export interface QueryService<K extends readonly unknown[], A, E> {
+    readonly keyStream: Stream.Stream<K>
     readonly state: SubscriptionRef.SubscriptionRef<AsyncData.AsyncData<A, E>>
     readonly refresh: Effect.Effect<Fiber.RuntimeFiber<void, Cause.NoSuchElementException>>
 }
 
 export const Tag = <const Id extends string>(id: Id) => <
-    Self, A, E = never,
->() => Effect.Tag(id)<Self, QueryService<A, E>>()
+    Self, K extends readonly unknown[], A, E = never,
+>() => Effect.Tag(id)<Self, QueryService<K, A, E>>()
 
 
 // export interface LayerProps<A, E, R> {