Thilawyn/effect-fc
1
0
Fork 0
Code Issues 1 Pull Requests 1 Actions Packages Projects Releases Wiki Activity

Working query
All checks were successful
Lint / lint (push) Successful in 40s
Details

Browse Source
This commit is contained in:
Julien Valverdé
2025-11-20 01:58:27 +01:00
parent 83128bb467
commit 140b2deda8
4 changed files with 112 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
packages/effect-fc/src/Query.ts
View File

@@ -32,23 +32,19 @@ extends Pipeable.Class() implements Query<K, A, E, R, P> {
super()
}
interrupt(): Effect.Effect<void> {
return Effect.andThen(this.fiber, Option.match({
readonly interrupt: Effect.Effect<void, never, never> = Effect.gen(this, function*() {
return yield* Effect.andThen(this.fiber, Option.match({
onSome: fiber => Effect.andThen(
Fiber.interrupt(fiber),
SubscriptionRef.set(this.fiber, Option.none()),
),
onNone: () => Effect.void,
}))
}
})
query(key: K): Effect.Effect<
Result.Result<A, E, P>,
never,
Result.unsafeForkEffect.OutputContext<A, E, R, P>
> {
query(key: K): Effect.Effect<Result.Result<A, E, P>, never, Scope.Scope | R> {
return this.fiber.pipe(
Effect.andThen(this.interrupt()),
Effect.andThen(this.interrupt),
Effect.andThen(Result.unsafeForkEffect(this.f(key), { initialProgress: this.initialProgress })),
Effect.tap(([, fiber]) => SubscriptionRef.set(this.fiber, Option.some(fiber))),
Effect.andThen(([sub]) => Effect.all([Effect.succeed(sub), sub.get])),
@@ -77,7 +73,7 @@ export const make = Effect.fnUntraced(function* <K extends readonly any[], A, E
): Effect.fn.Return<Query<K, A, E, Result.forkEffect.OutputContext<A, E, R, P>, P>> {
return new QueryImpl(
options.key,
options.f,
options.f as any,
options.initialProgress as P,
yield* SubscriptionRef.make(Option.none<Fiber.Fiber<A, E>>()),
@@ -87,14 +83,18 @@ export const make = Effect.fnUntraced(function* <K extends readonly any[], A, E
export const service = <K extends readonly any[], A, E = never, R = never, P = never>(
options: make.Options<K, A, E, R, P>
): Effect.Effect<Query<K, A, E, R, P>, never, Scope.Scope> => Effect.tap(
): Effect.Effect<
Query<K, A, E, Result.forkEffect.OutputContext<A, E, R, P>, P>,
never,
Scope.Scope | Result.forkEffect.OutputContext<A, E, R, P>
> => Effect.tap(
make(options),
query => Effect.forkScoped(run(query)),
)
export const run = <K extends readonly any[], A, E, R, P>(
self: Query<K, A, E, R, P>
) => Stream.runForEach(self.key, key => Effect.andThen(
(self as QueryImpl<K, A, E, R, P>).interrupt(),
): Effect.Effect<void, never, Scope.Scope | R> => Stream.runForEach(self.key, key => Effect.andThen(
(self as QueryImpl<K, A, E, R, P>).interrupt,
Effect.forkScoped((self as QueryImpl<K, A, E, R, P>).query(key)),
))