This document describes the current stable version of Kombu (5.3). For development docs, go here.

Event Loop Implementation - kombu.asynchronous.hub

Event loop implementation.

class kombu.asynchronous.hub.Hub(timer=None)[source]

Event loop object.

Arguments:

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.

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=<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]
fire_timers(min_delay=1, max_delay=10, max_timers=10, propagate=())[source]
property loop
on_callback_error(callback, exc)[source]
on_close = None

List of callbacks to be called when the loop is exiting, applied with the hub instance as sole argument.

property poller
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]
property scheduler
stop()[source]
kombu.asynchronous.hub.get_event_loop() Hub | None[source]

Get current event loop object.

kombu.asynchronous.hub.set_event_loop(loop: Hub | None) Hub | None[source]

Set the current event loop object.