Skip to content

BatchStreamMessage

faststream.redis.message.BatchStreamMessage #

Bases: _StreamMessage

type instance-attribute #

type: Literal['bstream']

data instance-attribute #

data: list[dict[bytes, bytes]]

channel instance-attribute #

channel: str

message_ids instance-attribute #

message_ids: list[bytes]

idle_times instance-attribute #

idle_times: NotRequired[list[int]]

delivery_counts instance-attribute #

delivery_counts: NotRequired[list[int]]