This document is for Kombu's development version, which can be significantly different from previous releases. Get the stable docs here: 4.5.
Event Loop - kombu.asynchronous
¶
Event loop.
-
class
kombu.asynchronous.
Hub
(timer=None)[source]¶ Event loop object.
- Parameters
timer (kombu.asynchronous.Timer) – Specify custom timer instance.
-
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.
-
create_loop
(generator=<class 'generator'>, sleep=<built-in function sleep>, min=<built-in function min>, next=<built-in function next>, Empty=<class '_queue.Empty'>, StopIteration=<class 'StopIteration'>, KeyError=<class 'KeyError'>, READ=1, WRITE=4, ERR=24)[source]¶
-
property
loop
¶
-
on_close
= None¶ List of callbacks to be called when the loop is exiting, applied with the hub instance as sole argument.
-
property
poller
¶