Function makeNet

packages/platform-node-shared/src/NodeSocket.ts:38–73

(
  options: Net.NetConnectOpts & {
    readonly openTimeout?: Duration.DurationInput | undefined
  }
)

 * @category constructors
 */
export const makeNet = (
  options: Net.NetConnectOpts & {
    readonly openTimeout?: Duration.DurationInput | undefined
  }
): Effect.Effect<Socket.Socket, Socket.SocketError> =>
  fromDuplex(
    Effect.scopeWith((scope) => {
      let conn: Net.Socket | undefined
      return Effect.flatMap(
        Scope.addFinalizer(
          scope,
          Effect.sync(() => {
            if (!conn) return
            if (conn.closed === false) {
              if ("destroySoon" in conn) {
                conn.destroySoon()
              } else {
                ;(conn as Net.Socket).destroy()
              }
            }
          })
        ),
        () =>
          Effect.async<Net.Socket, Socket.SocketError, never>((resume) => {
            conn = Net.createConnection(options)
            conn.once("connect", () => {
              resume(Effect.succeed(conn!))
            })
            conn.on("error", (cause) => {
              resume(Effect.fail(new Socket.SocketGenericError({ reason: "Open", cause })))
            })
          })
      )
    }),
    options
  )

/**
 * @since 1.0.0