Event loop implementation.
-
class kombu.async.hub.Hub(timer=None)
Event loop object.
Parameters: | timer – Specify timer object. |
-
ERR = 24
Flag set on error, and the fd should be read from asap.
-
READ = 1
Flag set if reading from an fd will not block.
-
WRITE = 4
Flag set if writing to an fd will not block.
-
add(fd, callback, flags, args=(), consolidate=False)
-
add_reader(fds, callback, *args)
-
add_writer(fds, callback, *args)
-
call_at(when, callback, *args)
-
call_later(delay, callback, *args)
-
call_repeatedly(delay, callback, *args)
-
call_soon(callback, *args)
-
close(*args)
-
create_loop(generator=<type 'generator'>, sleep=<built-in function sleep>, min=<built-in function min>, next=<built-in function next>, Empty=<class 'Queue.Empty'>, StopIteration=<type 'exceptions.StopIteration'>, KeyError=<type 'exceptions.KeyError'>, READ=1, WRITE=4, ERR=24)
-
fire_timers(min_delay=1, max_delay=10, max_timers=10, propagate=())
-
loop
-
on_close = None
List of callbacks to be called when the loop is exiting,
applied with the hub instance as sole argument.
-
remove(fd)
-
remove_reader(fd)
-
remove_writer(fd)
-
repr_active()
-
repr_events(events)
-
reset()
-
run_forever()
-
run_once()
-
scheduler
-
stop()
-
kombu.async.hub.get_event_loop()
-
kombu.async.hub.set_event_loop(loop)