This document is for Kombu's development version, which can be significantly different from previous releases. Get the stable docs here: 4.1.
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=<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]¶
-
loop
¶
-
on_close
= None¶ List of callbacks to be called when the loop is exiting, applied with the hub instance as sole argument.
-