Event Loop Implementation - kombu.async.hub¶
kombu.async.hub¶
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)¶