Loop

Event loop.

abstract

class Loop {

DList!Watcher pendings;

uint maxEvents [@property getter];

void unloop();

void start(ConnectionWatcher watcher);

void stop(ConnectionWatcher watcher);

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

inout(Duration) blockTime [@property getter];

Duration blockTime [@property setter];

Duration blockTime_;

}

Constructors

this this(): Initializes the loop.

Destructor

~this ~this(): Frees loop internals.

Members

Functions

poll void poll(): Does the actual polling.
reify bool reify(SocketWatcher watcher, EventMask oldEvents, EventMask events): Should be called if the backend configuration changes.
run void run(): Starts the loop.
start void start(ConnectionWatcher watcher): Start watching.
stop void stop(ConnectionWatcher watcher): Stop watching.
unloop void unloop(): Break out of the loop.

Properties

blockTime inout(Duration) blockTime [@property getter]
blockTime Duration blockTime [@property setter]: Sets the blocking time for IO watchers.
maxEvents uint maxEvents [@property getter]

Variables

blockTime_ Duration blockTime_;: Maximal block time.
done bool done;: Undocumented in source.
pendings DList!Watcher pendings;: Pending watchers.

Meta

Source

See Implementation

tanya async loop aliases

EventMask

classes

enums

Event

properties

defaultLoop