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.

@[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.

@[inline]

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

Listens for incoming connections with the given backlog.

@[inline]

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

Accepts an incoming connection.

@[inline]

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

Gets the local address of the server socket.

@[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.

@[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.

@[inline]

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

Creates a new TCP client socket.

@[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.

@[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.

@[inline]

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

Sends data through the client socket.

@[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. Furthermore calling this function in parallel with recvSelector is not supported.

def Std.Internal.IO.Async.TCP.Socket.Client.recvSelector (s : Client) (size : UInt64) : IO (Selector (Option ByteArray))

Creates a Selector that resolves once s has data available, up to at most size bytes, and provides that data. Calling this function starts the data wait, so it must not be called in parallel with recv?.

@[inline]

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

Shuts down the write side of the client socket.

@[inline]

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

Gets the remote address of the client socket.

@[inline]

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

Gets the local address of the client socket.

@[inline]

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

Enables the Nagle algorithm for the client socket.

@[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.