fix server interrupt (#25)

.changeset/curly-jeans-exercise.md

@@ -0,0 +1,5 @@
+---
+"@effect/experimental": patch
+---
+
+fix server interrupt

src/DevTools/Server.ts

@@ -46,14 +46,8 @@ export const make = Effect.gen(function*(_) {
 
   const handle = (socket: Socket.Socket) =>
     Effect.gen(function*(_) {
-      const responses = yield* _(Effect.acquireRelease(
-        Queue.unbounded<Domain.Response>(),
-        Queue.shutdown
-      ))
-      const requests = yield* _(Effect.acquireRelease(
-        Queue.unbounded<Domain.Span>(),
-        Queue.shutdown
-      ))
+      const responses = yield* _(Queue.unbounded<Domain.Response>())
+      const requests = yield* _(Queue.unbounded<Domain.Span>())
 
       yield* _(clients.offer(requests))
 
@@ -69,10 +63,13 @@ export const make = Effect.gen(function*(_) {
           req._tag === "Ping"
             ? responses.offer({ _tag: "Pong" })
             : requests.offer(req)
-        )
+        ),
+        Effect.ensuring(Effect.all([
+          requests.shutdown,
+          responses.shutdown
+        ]))
       )
     }).pipe(
-      Effect.scoped,
       Effect.catchAllCause(Effect.log),
       Effect.fork
     )

src/SocketServer/Node.ts

@@ -67,10 +67,10 @@ export const make = (
         )
       })
       server.listen(options)
-      return Effect.async<never, never, void>((resume) => {
+      return Effect.sync(() => {
         serverDeferred = Deferred.unsafeMake(fiberId)
         server.removeAllListeners()
-        server.close(() => resume(Effect.unit))
+        server.close()
       })
     }).pipe(
       semaphore.withPermits(1)
@@ -159,10 +159,10 @@ export const makeWebSocket = (
           Effect.runFork
         )
       })
-      return Effect.async<never, never, void>((resume) => {
+      return Effect.sync(() => {
         serverDeferred = Deferred.unsafeMake(fiberId)
         server.removeAllListeners()
-        server.close(() => resume(Effect.unit))
+        server.close()
       })
     }).pipe(
       semaphore.withPermits(1)