asynchronous.streams

High-level stream API.

Members

Classes

IncompleteReadError
class IncompleteReadError

Incomplete read error.

StreamReader
class StreamReader
StreamReaderProtocol
class StreamReaderProtocol

Helper class to adapt between $(D_PSYMBOL Protocol) and $(D_PSYMBOL StreamReader).

StreamWriter
class StreamWriter

Wraps a Transport.

Functions

openConnection
auto openConnection(EventLoop eventLoop, in char[] host = null, in char[] service = null, size_t limit = DEFAULT_LIMIT, SslContext sslContext = null, AddressFamily addressFamily = UNSPECIFIED!AddressFamily, ProtocolType protocolType = UNSPECIFIED!ProtocolType, AddressInfoFlags addressInfoFlags = UNSPECIFIED!AddressInfoFlags, Socket socket = null, in char[] localHost = null, in char[] localService = null, in char[] serverHostname = null)

A wrapper for $(D_PSYMBOL createConnection()) returning a (reader, writer) pair.

openUnixConnection
auto openUnixConnection(EventLoop eventLoop, in char[] path = null, size_t limit = DEFAULT_LIMIT, SslContext sslContext = null, Socket socket = null, in char[] serverHostname = null)

A wrapper for $(D_PSYMBOL createUnixConnection()) returning a (reader, writer) pair.

startServer
Server startServer(EventLoop eventLoop, ClientConnectedCallback clientConnectedCallback, in char[] host = null, in char[] service = null, size_t limit = DEFAULT_LIMIT, AddressFamily addressFamily = UNSPECIFIED!AddressFamily, AddressInfoFlags addressInfoFlags = AddressInfoFlags.PASSIVE, Socket socket = null, int backlog = 100, SslContext sslContext = null, bool reuseAddress = true)

Start a socket server, call back for each client connected.

startUnixServer
Server startUnixServer(EventLoop eventLoop, ClientConnectedCallback clientConnectedCallback, in char[] path = null, size_t limit = DEFAULT_LIMIT, Socket socket = null, int backlog = 100, SslContext sslContext = null)

Start a UNIX Domain Socket server, with a callback for each client connected.

Meta

Authors

Dragos Carp

License

Boost Software License - Version 1.0