Function onConnection_

packages/platform-node-shared/src/NodeSocketServer.ts:70–104

(conn: Net.Socket)

    )
    const run = yield* FiberSet.runtime(fiberSet)<R>()
    function onConnection_(conn: Net.Socket) {
      let error: Error | undefined
      conn.on("error", (err) => {
        error = err
      })
      pipe(
        NodeSocket.fromDuplex(
          Effect.acquireRelease(
            Effect.suspend((): Effect.Effect<Net.Socket, Socket.SocketError> => {
              if (error) {
                return Effect.fail(new Socket.SocketGenericError({ reason: "Open", cause: error }))
              } else if (conn.closed) {
                return Effect.fail(
                  new Socket.SocketCloseError({
                    reason: "Close",
                    code: 1000
                  })
                )
              }
              return Effect.succeed(conn)
            }),
            (conn) =>
              Effect.sync(() => {
                if (conn.closed === false) {
                  conn.destroySoon()
                }
              })
          )
        ),
        Effect.flatMap(handler),
        Effect.catchAllCause(reportUnhandledError),
        Effect.provideService(NodeSocket.NetSocket, conn),
        run
      )
    }
    return yield* Effect.async<never>((_resume) => {
      const prev = onConnection
      onConnection = onConnection_