diff --git a/packages/extension-query/src/MutationRunner.ts b/packages/extension-query/src/MutationRunner.ts index 25334d9..83045c3 100644 --- a/packages/extension-query/src/MutationRunner.ts +++ b/packages/extension-query/src/MutationRunner.ts @@ -58,9 +58,12 @@ export const make = ( const forkMutate = (...key: K) => Queue.unbounded>>().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)