KqueueLoop

Undocumented in source.

version(MacBSD)

final

class KqueueLoop : SelectorLoop {

uint maxEvents [@property getter];

bool reify(SocketWatcher watcher, EventMask oldEvents, EventMask events);

inout(Duration) blockTime [@property getter];

bool feed(StreamTransport transport, SocketException exception);

}

Constructors

this this(): Undocumented in source.

Destructor

~this ~this(): Frees loop internals.

Members

Functions

feed bool feed(StreamTransport transport, SocketException exception): If the transport couldn't send the data, the further sending should be handled by the event loop.
poll void poll(): Does the actual polling.
reify bool reify(SocketWatcher watcher, EventMask oldEvents, EventMask events): Should be called if the backend configuration changes.

Properties

blockTime inout(Duration) blockTime [@property getter]
maxEvents uint maxEvents [@property getter]

Variables

fd int fd;: Undocumented in source.

Inherited Members

From SelectorLoop

connections Array!SocketWatcher connections;: Pending connections.
~this ~this(): Undocumented in source.
reify bool reify(SocketWatcher watcher, EventMask oldEvents, EventMask events): Should be called if the backend configuration changes.
kill void kill(StreamTransport transport, SocketException exception): Kills the watcher and closes the connection.
feed bool feed(StreamTransport transport, SocketException exception): If the transport couldn't send the data, the further sending should be handled by the event loop.
start void start(ConnectionWatcher watcher): Start watching.
acceptConnections void acceptConnections(ConnectionWatcher connection): Accept incoming connections.

Meta

Source

See Implementation

tanya async event kqueue classes

KqueueLoop

enums

functions

structs

kevent_t