Event Loop - kombu.async¶
kombu.async¶
Event loop implementation.
-
class
kombu.async.
Hub
(timer=None)¶ Event loop object.
Parameters: timer – Specify timer object. -
ERR
= 24¶
-
READ
= 1¶
-
WRITE
= 4¶
-
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¶
-
remove
(fd)¶
-
remove_reader
(fd)¶
-
remove_writer
(fd)¶
-
repr_active
()¶
-
repr_events
(events)¶
-
reset
()¶
-
run_forever
()¶
-
run_once
()¶
-
scheduler
¶
-
stop
()¶
-
-
kombu.async.
get_event_loop
()¶
-
kombu.async.
set_event_loop
(loop)¶