Attributes

Class: KQueuePoller

Methods

add (self, op, coro)

~ @debug(0)

handle_errored (self, desc)

remove (self, op, coro)

~ @debug(0)

run (self, timeout=0)

Run a poller loop and return new socket events. Timeout is a timedelta object, 0 if active coros or None.

kqueue timeout param is a integer number of nanoseconds (seconds/10**9).

run_once (self, fdesc, waiting_ops)

Run a operation, remove it from the poller and return the result. Called from the main poller loop.

run_operation (self, op)

Run the socket op and return result or exception.

run_or_add (self, op, coro)

Perform operation or add the operation in the poller if socket isn't ready. Called from the scheduller.

waiting_op (self, testcoro)

Attributes

Value of

None

Value of

None

Value of

None