base¶
- class litestar.channels.backends.base.ChannelsBackend¶
Bases:
ABC
- abstractmethod async publish(data: bytes, channels: Iterable[str]) None ¶
Publish the message
data
to allchannels
- abstractmethod async subscribe(channels: Iterable[str]) None ¶
Start listening for events on
channels
- abstractmethod async unsubscribe(channels: Iterable[str]) None ¶
Stop listening for events on
channels