Modulestreamly-0.10.1Haskell2010

Streamly.Network.Inet.TCP

Combinators to build Inet/IPv4/TCP clients and servers.

Example1 expression

>>> import qualified Streamly.Network.Inet.TCP as TCP

Examples

Following is a short example of a concurrent echo server.

Example11 expressions

>>> import Control.Monad.Catch (finally)>>> import Data.Function ((&))>>> import Network.Socket (Socket)>>> >>> import qualified Network.Socket as Net>>> import qualified Streamly.Data.Fold as Fold>>> import qualified Streamly.Data.Stream.Prelude as Stream>>> import qualified Streamly.Network.Inet.TCP as TCP>>> import qualified Streamly.Network.Socket as Socket>>> >>> :{main :: IO ()main =      TCP.accept 8091                            -- Stream IO Socket    & Stream.parMapM id (handleExceptions echo)  -- Stream IO ()    & Stream.fold Fold.drain                     -- IO ()    where    echo :: Socket -> IO ()    echo sk =          Socket.readChunksWith 32768 sk      -- Stream IO (Array Word8)        & Stream.fold (Socket.writeChunks sk) -- IO ()    handleExceptions :: (Socket -> IO ()) -> Socket -> IO ()    handleExceptions f sk = finally (f sk) (Net.close sk):}

10 values

Packagestreamly-0.10.1
Exports10
LanguageHaskell2010
LicenceBSD-3-Clause
SourceTCP.hs

Accept Connections

0 declarations

Streams

valueaccept :: MonadIO m => PortNumber -> Stream m Socket

Start a TCP stream server that binds on the IPV4 address 0.0.0.0 and listens for TCP connections from remote hosts on the specified server port. The server generates a stream of connected sockets.

Example1 expression

>>> accept = TCP.acceptOnAddr (0,0,0,0)

Pre-release

valueacceptLocal :: MonadIO m => PortNumber -> Stream m Socket

Like accept but binds on the localhost IPv4 address 127.0.0.1. The server can only be accessed from the local host, it cannot be accessed from other hosts on the network.

Example1 expression

>>> acceptLocal = TCP.acceptOnAddr (127,0,0,1)

Pre-release

valueacceptOnAddr

:: MonadIO m
=> (Word8, Word8, Word8, Word8)
-> PortNumber
-> Stream m Socket

Like accept but binds on the specified IPv4 address.

Example1 expression

>>> acceptOnAddr = TCP.acceptOnAddrWith []

Pre-release

valueacceptOnAddrWith

:: MonadIO m
=> [(SocketOption, Int)]
-> (Word8, Word8, Word8, Word8)
-> PortNumber
-> Stream m Socket

Like acceptOnAddr but with the ability to specify a list of socket options.

Pre-release

Unfolds

valueacceptor :: MonadIO m => Unfold m PortNumber Socket

Like acceptorOnAddr but binds on the IPv4 address 0.0.0.0 i.e. on all IPv4 addresses/interfaces of the machine and listens for TCP connections on the specified port.

Example1 expression

>>> acceptor = Unfold.first (0,0,0,0) TCP.acceptorOnAddr

valueacceptorLocal :: MonadIO m => Unfold m PortNumber Socket

Like acceptor but binds on the localhost IPv4 address 127.0.0.1. The server can only be accessed from the local host, it cannot be accessed from other hosts on the network.

Example1 expression

>>> acceptorLocal = Unfold.first (127,0,0,1) TCP.acceptorOnAddr

valueacceptorOnAddr :: MonadIO m => Unfold m ((Word8, Word8, Word8, Word8), PortNumber) Socket

Unfold a tuple (ipAddr, port) into a stream of connected TCP sockets. ipAddr is the local IP address and port is the local port on which connections are accepted.

Connect to Servers

1 declaration

valueconnect :: (Word8, Word8, Word8, Word8) -> PortNumber -> IO Socket

Connect to the specified IP address and port number. Returns a connected socket or throws an exception.

Deprecated

2 declarations

valueacceptorOnPort :: MonadIO m => Unfold m PortNumber Socket

Deprecated. Use "acceptor" instead.

valueacceptorOnPortLocal :: MonadIO m => Unfold m PortNumber Socket

Deprecated. Use "acceptorLocal" instead.