Share via


broadcast_queue Module

Classes

BroadcastQueue

A queue for broadcasting messages to listeners.

Note: This class is marked as 'experimental' and may change in the future.

Create a new model by parsing and validating input data from keyword arguments.

Raises [ValidationError][pydantic_core.ValidationError] if the input data cannot be validated to form a valid model.

self is explicitly positional-only to allow self as a field name.

ChannelReference

Tracks a channel along with its hashed key.

Note: This class is marked as 'experimental' and may change in the future.

QueueReference

Utility class to associate a queue with its specific lock.

Note: This class is marked as 'experimental' and may change in the future.

Create a new model by parsing and validating input data from keyword arguments.

Raises [ValidationError][pydantic_core.ValidationError] if the input data cannot be validated to form a valid model.

self is explicitly positional-only to allow self as a field name.