From 6edac19fa62e618e6738efb77d0a1b4d251f7063 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Julien=20Valverd=C3=A9?= <julien.valverde@mailo.com>
Date: Fri, 23 May 2025 05:12:21 +0200
Subject: [PATCH] Service work

---
 packages/extension-query/src/QueryService.ts | 15 ++++++++++++++-
 1 file changed, 14 insertions(+), 1 deletion(-)

diff --git a/packages/extension-query/src/QueryService.ts b/packages/extension-query/src/QueryService.ts
index 687ebf0..6ef7d91 100644
--- a/packages/extension-query/src/QueryService.ts
+++ b/packages/extension-query/src/QueryService.ts
@@ -1,6 +1,7 @@
 import type * as AsyncData from "@typed/async-data"
 import { type Cause, Effect, type Fiber, type Option, type Stream, type SubscriptionRef } from "effect"
 import * as QueryRunner from "./QueryRunner.js"
+import * as QueryProgress from "./QueryProgress.js"
 
 
 export const Tag = <const Id extends string>(id: Id) => <
@@ -8,4 +9,16 @@ export const Tag = <const Id extends string>(id: Id) => <
 >() => Effect.Tag(id)<Self, QueryRunner.QueryRunner<K, A, E>>()
 
 
-export const Service = <Self>() =>
+export interface ServiceProps<K extends readonly unknown[], A, E, R> {
+    readonly key: Stream.Stream<K>
+    readonly query: (key: K) => Effect.Effect<A, E, R | QueryProgress.QueryProgress>
+    readonly options?: QueryRunner.RunOptions
+}
+
+export const Service = <Self>() => <
+    const Id extends string,
+    K extends readonly unknown[], A, E, R,
+>(
+    id: Id,
+    props: ServiceProps<K, A, E, R>,
+) =>