This document describes the current stable version of Kombu (4.1).
For development docs,
go here.
Event Loop - kombu.async
Event loop.
-
class
kombu.async.
Hub
(timer=None)[source]
Event loop object.
Parameters: | timer (kombu.async.Timer) – Specify custom timer instance. |
-
ERR
= 24
-
READ
= 1
-
WRITE
= 4
-
add
(fd, callback, flags, args=(), consolidate=False)[source]
-
add_reader
(fds, callback, *args)[source]
-
add_writer
(fds, callback, *args)[source]
-
call_at
(when, callback, *args)[source]
-
call_later
(delay, callback, *args)[source]
-
call_repeatedly
(delay, callback, *args)[source]
-
call_soon
(callback, *args)[source]
-
close
(*args)[source]
-
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)[source]
-
fire_timers
(min_delay=1, max_delay=10, max_timers=10, propagate=())[source]
-
loop
-
on_callback_error
(callback, exc)[source]
-
on_close
= None
-
remove
(fd)[source]
-
remove_reader
(fd)[source]
-
remove_writer
(fd)[source]
-
repr_active
()[source]
-
repr_events
(events)[source]
-
reset
()[source]
-
run_forever
()[source]
-
run_once
()[source]
-
scheduler
[source]
-
stop
()[source]
-
kombu.async.
get_event_loop
()[source]
Get current event loop object.
-
kombu.async.
set_event_loop
(loop)[source]
Set the current event loop object.