Streaming.UDP

Documentation

fromUDP

Arguments

:: MonadResource m

=> String

address to bind to

-> PortNumber

port number to bind to

-> Int

maximum size of a datagram

-> Stream (Of (ByteString, SockAddr)) m r

Fire-and-forget style UDP source. It will attempt to listen on the specified interface and port, and if it succeeds it can read contents being sent to that interface and port. It streams a pair of (message, source-address) allowing the downstream to know who sent the message.

fromSocket

Arguments

:: MonadIO m

=> Socket

the socket

-> Int

max lenght of a datagram

-> Stream (Of (ByteString, SockAddr)) m r

the resulting stream of messages

Stream the contents of a bound Socket as binary data. Note that this function will not automatically close the Socket when processing completes, since it did not acquire the Socket in the first place.

fromIOSocket

Arguments

:: MonadResource m

=> IO Socket

the IO action to create the UDP socket

-> Int

max length of a datagram

-> Stream (Of (ByteString, SockAddr)) m r

the resulting stream of messages

An alternative to fromSocket. Instead of taking a pre-bound Socket, it takes an action that opens and binds a Socket, so that it can open it only when needed and close it as soon as possible.

toUDP :: MonadResource m => String -> PortNumber -> Stream (Of (ByteString, SockAddr)) m r -> m r

gets an ip adress, a port and stream of strict pairs (ByteString, SockAddr) and sends all the ByteStrings to the SockAddr from a socet bounded to the give ip and port.

Note: before 0.2.0.0 this function had a different specification.

Since: 0.2.0.0

toSocket :: MonadIO m => Socket -> Stream (Of (ByteString, SockAddr)) m r -> m r

Stream all incoming data to the given connected Socket. Note that this function will not automatically close the Socket when processing completes.

Note: before 0.2.0.0 this function had a different specification.

Since: 0.2.0.0

toIOSocket :: MonadResource m => IO Socket -> Stream (Of (ByteString, SockAddr)) m r -> m r

An alternative to toSocket. Instead of taking a pre-opened Socket, it takes an action that returns a connected Socket , so that it can open it only when needed and close it as soon as possible.

Note: before 0.2.0.0 this function had a different specification.

Since: 0.2.0.0

Reexports

inet_addr :: String -> IO HostAddress

data SockAddr :: *

The existence of a constructor does not necessarily imply that that socket address type is supported on your system: see isSupportedSockAddr.

Constructors

SockAddrInet PortNumber HostAddress

Instances

Eq SockAddr

Methods

(==) :: SockAddr -> SockAddr -> Bool

(/=) :: SockAddr -> SockAddr -> Bool

Ord SockAddr

Methods

compare :: SockAddr -> SockAddr -> Ordering

(<) :: SockAddr -> SockAddr -> Bool

(<=) :: SockAddr -> SockAddr -> Bool

(>) :: SockAddr -> SockAddr -> Bool

(>=) :: SockAddr -> SockAddr -> Bool

max :: SockAddr -> SockAddr -> SockAddr

min :: SockAddr -> SockAddr -> SockAddr