asynchronous.streams

High-level stream API.

Members

Aliases

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

Classes

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.

Functions

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.

Manifest constants

DEFAULT_LIMIT
enum DEFAULT_LIMIT;
Undocumented in source.

Meta