asynchronous.streams

High-level stream API.

Members

ClientConnectedCallback alias ClientConnectedCallback = void delegate(StreamReader, StreamWriter): Undocumented in source.

IncompleteReadError class IncompleteReadError: Incomplete read error.
StreamReader class StreamReader: Undocumented in source.
StreamReaderProtocol class StreamReaderProtocol: Helper class to adapt between $(D_PSYMBOL Protocol) and $(D_PSYMBOL StreamReader).
StreamWriter class StreamWriter: Wraps a Transport.

openConnection auto openConnection(EventLoop eventLoop, char[] host, char[] service, size_t limit, SslContext sslContext, AddressFamily addressFamily, ProtocolType protocolType, AddressInfoFlags addressInfoFlags, Socket socket, char[] localHost, char[] localService, char[] serverHostname): A wrapper for $(D_PSYMBOL createConnection()) returning a (reader, writer) pair.
openUnixConnection auto openUnixConnection(EventLoop eventLoop, char[] path, size_t limit, SslContext sslContext, Socket socket, char[] serverHostname): A wrapper for $(D_PSYMBOL createUnixConnection()) returning a (reader, writer) pair.
startServer Server startServer(EventLoop eventLoop, ClientConnectedCallback clientConnectedCallback, char[] host, char[] service, size_t limit, AddressFamily addressFamily, AddressInfoFlags addressInfoFlags, Socket socket, int backlog, SslContext sslContext, bool reuseAddress): Start a socket server, call back for each client connected.
startUnixServer Server startUnixServer(EventLoop eventLoop, ClientConnectedCallback clientConnectedCallback, char[] path, size_t limit, Socket socket, int backlog, SslContext sslContext): Start a UNIX Domain Socket server, with a callback for each client connected.