Struct MessageChannel 

pub struct MessageChannel { /* private fields */ }

实时消息通道。Clone 即克隆底层 sender,可多生产者并发推送。

Implementations

impl MessageChannel

pub fn new() -> (Self, UnboundedReceiver<AgentMessage>)

创建通道,返回 (channel, receiver)。所有 channel 副本 drop 后,receiver 收到 None。

pub fn disconnected() -> Self

一个没有消费者的通道:send 全部静默丢弃。未配置 messages 时的默认值。

pub fn send(&self, session_id: &str, kind: MessageKind)

投递一条消息。fire-and-forget:消费者已断开则静默丢弃,不阻断主流程。

Trait Implementations

impl Clone for MessageChannel

fn clone(&self) -> MessageChannel

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for MessageChannel

fn default() -> Self

Returns the “default value” for a type.