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

Fix
All checks were successful
Lint / lint (push) Successful in 12s
Details

Browse Source
This commit is contained in:
Julien Valverdé
2025-11-02 21:00:12 +01:00
parent 0b8418e114
commit 4f69f667b0
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
packages/effect-fc/src/Result.ts
View File

@@ -239,7 +239,10 @@ export const forkEffectDequeue = <A, E, R, P = never>(
Effect.tap(([ref, queue]) => Effect.forkScoped(State<A, E, P>().pipe( Effect.tap(([ref, queue]) => Effect.forkScoped(State<A, E, P>().pipe(
Effect.andThen(state => state.set(running(options?.initialProgress)).pipe( Effect.andThen(state => state.set(running(options?.initialProgress)).pipe(
Effect.andThen(effect), Effect.andThen(effect),
Effect.onExit(exit => Effect.andThen(state.set(fromExit(exit)), Queue.shutdown(queue))), Effect.onExit(exit => Effect.andThen(
state.set(fromExit(exit)),
Effect.forkScoped(Queue.shutdown(queue)),
)),
)), )),
Effect.provide(Layer.empty.pipe( Effect.provide(Layer.empty.pipe(
Layer.provideMerge(makeProgressLayer<A, E, P>()), Layer.provideMerge(makeProgressLayer<A, E, P>()),