structure Data.Streaming.Network.AppData : Type

Application data for a connected client.

• appRead : IO ByteArray

  Read data from the connection.

• appWrite : ByteArray → IO Unit

  Write data to the connection.

• appSockAddr : Network.Socket.SockAddr

  The client's address.

• appClose : IO Unit

  Close the connection.

def Data.Streaming.Network.bindPortTCP (port : UInt16) (host : String := "0.0.0.0") : IO (Network.Socket.Socket Network.Socket.SocketState.listening)

Bind a TCP server socket to a port. Returns a listening socket. $$\text{bindPortTCP} : \text{UInt16} \to \text{String} \to \text{IO}(\text{Socket}\ \texttt{.listening})$$

Equations

• Data.Streaming.Network.bindPortTCP port host = Network.Socket.listenTCP host port

def Data.Streaming.Network.getSocketTCP (host : String) (port : UInt16) : IO (Network.Socket.Socket Network.Socket.SocketState.connected × Network.Socket.SockAddr)

Connect to a remote TCP server. Returns a connected socket and the address. $$\text{getSocketTCP} : \text{String} \to \text{UInt16} \to \text{IO}(\text{Socket}\ \texttt{.connected} \times \text{SockAddr})$$

Equations

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

partial def Data.Streaming.Network.acceptSafe (serverSock : Network.Socket.Socket Network.Socket.SocketState.listening) : IO (Network.Socket.Socket Network.Socket.SocketState.connected × Network.Socket.SockAddr)

Accept a connection on a listening socket, retrying on transient errors. $$\text{acceptSafe} : \text{Socket}\ \texttt{.listening} \to \text{IO}(\text{Socket}\ \texttt{.connected} \times \text{SockAddr})$$

def Data.Streaming.Network.mkAppData (clientSock : Network.Socket.Socket Network.Socket.SocketState.connected) (addr : Network.Socket.SockAddr) : AppData

Create AppData from a connected socket.

Equations

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

def Data.Streaming.Network.runTCPServer (port : UInt16) (handler : AppData → IO Unit) : IO Unit

Run a TCP server: accept connections and handle each in a new task. $$\text{runTCPServer} : \text{UInt16} \to (\text{AppData} \to \text{IO}(\text{Unit})) \to \text{IO}(\text{Unit})$$

Equations

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