snakia.core.es.subscriber

Functions

NamedTuple(typename[, fields])

Typed version of namedtuple.

Classes

Event(**data)

Filter(*args, **kwargs)

Filter for an event.

Generic()

Abstract base class for generic types.

Handler(*args, **kwargs)

Handler for an event.

Subscriber(handler, filters, priority)

Subscriber for an event.

TypeVar(name, *constraints[, bound, ...])

Type variable.

class snakia.core.es.subscriber.Subscriber(handler: Handler[T_contra], filters: Filter[T_contra] | None, priority: int)[source]

Bases: NamedTuple, Generic[T_contra]

Subscriber for an event.

count(value, /)

Return number of occurrences of value.

filters: Optional[Filter[TypeVar(T_contra, bound= Event, contravariant=True)]]

Alias for field number 1

handler: Handler[TypeVar(T_contra, bound= Event, contravariant=True)]

Alias for field number 0

index(value, start=0, stop=9223372036854775807, /)

Return first index of value.

Raises ValueError if the value is not present.

priority: int

Alias for field number 2