return self._running
def add_timeout(self, deadline, callback):
- """Calls the given callback at the time deadline from the I/O loop."""
+ """Calls the given callback at the time deadline from the I/O loop.
+
+ Returns a handle that may be passed to remove_timeout to cancel.
+ """
timeout = _Timeout(deadline, stack_context.wrap(callback))
bisect.insort(self._timeouts, timeout)
return timeout
def remove_timeout(self, timeout):
+ """Cancels a pending timeout.
+
+ The argument is a handle as returned by add_timeout.
+ """
self._timeouts.remove(timeout)
def add_callback(self, callback):