From 085290535f0d85717d62c7889f362bc1eef81801 Mon Sep 17 00:00:00 2001
From: Julius Marminge <julius0216@outlook.com>
Date: Wed, 1 Apr 2026 00:28:03 -0700
Subject: [PATCH] migrate Effect.fn in packages/shared/src/DrainableWorker.ts

Co-authored-by: codex <codex@users.noreply.github.com>
---
 packages/shared/src/DrainableWorker.ts | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/packages/shared/src/DrainableWorker.ts b/packages/shared/src/DrainableWorker.ts
index 55483f33e8..f0d22ba1e4 100644
--- a/packages/shared/src/DrainableWorker.ts
+++ b/packages/shared/src/DrainableWorker.ts
@@ -38,7 +38,11 @@ export interface DrainableWorker<A> {
 export const makeDrainableWorker = <A, E, R>(
   process: (item: A) => Effect.Effect<void, E, R>,
 ): Effect.Effect<DrainableWorker<A>, never, Scope.Scope | R> =>
-  Effect.gen(function* () {
+  Effect.fn("makeDrainableWorker")(function* (): Effect.fn.Return<
+    DrainableWorker<A>,
+    never,
+    Scope.Scope | R
+  > {
     const queue = yield* Effect.acquireRelease(TxQueue.unbounded<A>(), TxQueue.shutdown);
     const outstanding = yield* TxRef.make(0);
 
@@ -65,4 +69,4 @@ export const makeDrainableWorker = <A, E, R>(
       );
 
     return { enqueue, drain } satisfies DrainableWorker<A>;
-  });
+  })();