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

This commit is contained in:
Julien Valverdé
2025-03-18 02:46:41 +01:00
parent 65a124de1f
commit f85173fa68

View File

@@ -58,9 +58,12 @@ export const make = <EH, K extends readonly unknown[], A, E, HandledE, R>(
const forkMutate = (...key: K) => Queue.unbounded<AsyncData.AsyncData<A, Exclude<E, HandledE>>>().pipe(
Effect.flatMap(stateQueue =>
run(key, value => Queue.offer(stateQueue, value).pipe(
Effect.andThen(Ref.set(stateRef, value))
)).pipe(
run(
key,
value => Ref.set(stateRef, value).pipe(
Effect.andThen(Queue.offer(stateQueue, value))
),
).pipe(
Effect.tap(() => Queue.shutdown(stateQueue)),
Effect.forkDaemon,
Effect.map(fiber => [fiber, Stream.fromQueue(stateQueue)] as const)