snakia.core.es.dispatcher

Functions

nolock()

Classes

Dispatcher()	Event dispatcher
Event(**data)
Filter(*args, **kwargs)	Filter for an event.
Handler(*args, **kwargs)	Handler for an event.
Subscriber(handler, filters, priority)	Subscriber for an event.
TypeVar(name, *constraints[, bound, ...])	Type variable.
defaultdict	defaultdict(default_factory=None, /, [...]) --> dict with default factory

class snakia.core.es.dispatcher.Dispatcher

Bases: object

Event dispatcher

__init__()

property is_running: bool

Returns True if the dispatcher is running.

on(event, filter=None, priority=-1)

Decorator to subscribe to an event.

Return type:

Callable[[Handler[TypeVar(T, bound= Event)]], Handler[TypeVar(T, bound= Event)]]

publish(event)

Add an event to the queue.

Return type:

None

start()

Start the update loop.

Return type:

None

stop()

Stop the update loop.

Return type:

None

subscribe(event_type, subscriber)

Subscribe to an event type.

Return type:

None

unsubscribe(event_type, subscriber)

Unsubscribe from an event type.

Return type:

None

update(block=False)

Update the dispatcher.

Return type:

None