structure Std.Internal.IO.Async.TCP.Socket.Server : Type

Represents a TCP server socket, managing incoming client connections.

• ofNative :: (
• native : UV.TCP.Socket
• )

structure Std.Internal.IO.Async.TCP.Socket.Client : Type

Represents a TCP client socket, used to connect to a server.

• ofNative :: (
• native : UV.TCP.Socket
• )

@[inline]

def Std.Internal.IO.Async.TCP.Socket.Server.mk : IO Server

Creates a new TCP server socket.

Equations

• Std.Internal.IO.Async.TCP.Socket.Server.mk = do let native ← Std.Internal.UV.TCP.Socket.new pure { native := native }

@[inline]

def Std.Internal.IO.Async.TCP.Socket.Server.bind (s : Server) (addr : Net.SocketAddress) : IO Unit

Binds the server socket to the specified address. Address reuse is enabled to allow rebinding the same address.

Equations

• s.bind addr = s.native.bind addr

@[inline]

def Std.Internal.IO.Async.TCP.Socket.Server.listen (s : Server) (backlog : UInt32) : IO Unit

Listens for incoming connections with the given backlog.

Equations

• s.listen backlog = s.native.listen backlog

@[inline]

def Std.Internal.IO.Async.TCP.Socket.Server.accept (s : Server) : IO (AsyncTask Client)

Accepts an incoming connection.

Equations

• One or more equations did not get rendered due to their size.

@[inline]

def Std.Internal.IO.Async.TCP.Socket.Server.getSockName (s : Server) : IO Net.SocketAddress

Gets the local address of the server socket.

Equations

• s.getSockName = s.native.getSockName

@[inline]

def Std.Internal.IO.Async.TCP.Socket.Server.noDelay (s : Server) : IO Unit

Enables the Nagle algorithm for all client sockets accepted by this server socket.

Equations

• s.noDelay = s.native.noDelay

@[inline]

def Std.Internal.IO.Async.TCP.Socket.Server.keepAlive (s : Server) (enable : Bool) (delay : Time.Second.Offset) : autoParam (delay.val ≥ 1) _auto✝ → IO Unit

Enables TCP keep-alive for all client sockets accepted by this server socket.

Equations

• s.keepAlive enable delay x✝ = s.native.keepAlive enable.toInt8 delay.val.toNat.toUInt32

@[inline]

def Std.Internal.IO.Async.TCP.Socket.Client.mk : IO Client

Creates a new TCP client socket.

Equations

• Std.Internal.IO.Async.TCP.Socket.Client.mk = do let native ← Std.Internal.UV.TCP.Socket.new pure { native := native }

@[inline]

def Std.Internal.IO.Async.TCP.Socket.Client.bind (s : Client) (addr : Net.SocketAddress) : IO Unit

Binds the server socket to the specified address. Address reuse is enabled to allow rebinding the same address.

Equations

• s.bind addr = s.native.bind addr

@[inline]

def Std.Internal.IO.Async.TCP.Socket.Client.connect (s : Client) (addr : Net.SocketAddress) : IO (AsyncTask Unit)

Connects the client socket to the given address.

Equations

• s.connect addr = Std.Internal.IO.Async.AsyncTask.ofPromise <$> s.native.connect addr

@[inline]

def Std.Internal.IO.Async.TCP.Socket.Client.send (s : Client) (data : ByteArray) : IO (AsyncTask Unit)

Sends data through the client socket.

Equations

• s.send data = Std.Internal.IO.Async.AsyncTask.ofPromise <$> s.native.send data

@[inline]

def Std.Internal.IO.Async.TCP.Socket.Client.recv? (s : Client) (size : UInt64) : IO (AsyncTask (Option ByteArray))

Receives data from the client socket. If data is received, it’s wrapped in .some. If EOF is reached, the result is .none, indicating no more data is available. Receiving data in parallel on the same socket is not supported. Instead, we recommend binding multiple sockets to the same address.

Equations

• s.recv? size = Std.Internal.IO.Async.AsyncTask.ofPromise <$> s.native.recv? size

@[inline]

def Std.Internal.IO.Async.TCP.Socket.Client.shutdown (s : Client) : IO (AsyncTask Unit)

Shuts down the write side of the client socket.

Equations

• s.shutdown = Std.Internal.IO.Async.AsyncTask.ofPromise <$> s.native.shutdown

@[inline]

def Std.Internal.IO.Async.TCP.Socket.Client.getPeerName (s : Client) : IO Net.SocketAddress

Gets the remote address of the client socket.

Equations

• s.getPeerName = s.native.getPeerName

@[inline]

def Std.Internal.IO.Async.TCP.Socket.Client.getSockName (s : Client) : IO Net.SocketAddress

Gets the local address of the client socket.

Equations

• s.getSockName = s.native.getSockName

@[inline]

def Std.Internal.IO.Async.TCP.Socket.Client.noDelay (s : Client) : IO Unit

Enables the Nagle algorithm for the client socket.

Equations

• s.noDelay = s.native.noDelay

@[inline]

def Std.Internal.IO.Async.TCP.Socket.Client.keepAlive (s : Client) (enable : Bool) (delay : Time.Second.Offset) : autoParam (delay.val ≥ 0) _auto✝ → IO Unit

Enables TCP keep-alive with a specified delay for the client socket.

Equations

• s.keepAlive enable delay x✝ = s.native.keepAlive enable.toInt8 delay.val.toNat.toUInt32