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)

Table Of Contents

Previous topic

Async Utilities - kombu.syn

Next topic

Event Loop Implementation - kombu.async.hub

This Page