memory

class litestar.channels.backends.memory.MemoryChannelsBackend

基类：ChannelsBackend

一个内存中的 channels 后端

__init__(history: int = 0) → None

async on_startup() → None

Called by the plugin on application startup

async on_shutdown() → None

Called by the plugin on application shutdown

async publish(data: bytes, channels: Iterable[str]) → None

将 data 发布到 channels。如果某个频道尚未订阅，此操作将无效。 Args: data: 要发布的数据 channels: 要发布到的频道 Returns: None Raises: RuntimeError: 如果尚未调用 on_startup

async subscribe(channels: Iterable[str]) → None

订阅 channels，并启用向它们发布消息的功能

async unsubscribe(channels: Iterable[str]) → None

从 channels 取消订阅

async stream_events() → AsyncGenerator[tuple[str, Any], None]

返回一个生成器，迭代订阅通道的可用事件。

async get_history(channel: str, limit: int | None = None) → list[bytes]

返回 channel 的事件历史，最多包含 limit 条记录