Struct Writer 

pub struct Writer { /* private fields */ }

单写者句柄：可廉价克隆，所有克隆共享同一个写任务。

帧由 Writer::send 编码，因此超限帧在入队前即被拒绝。队列无界、不提供背压； 写任务因 I/O 错误退出或接收端被丢弃后，后续发送返回 runtime_unavailable。

Implementations

impl Writer

pub fn channel(max_frame_size: usize) -> (Self, UnboundedReceiver<Bytes>)

创建一个不绑定 I/O 的写句柄及其接收端，接收端得到的是不含外层长度前缀的帧数据。

主要用于测试，或由调用方自行驱动写出；生产环境使用 Writer::spawn。

pub fn spawn<W: AsyncWrite + Unpin + Send + 'static>( stream: W, max_frame_size: usize, ) -> Self

启动后台写任务，把帧加上 u32 大端长度前缀后依次写入 stream。

写入失败时记录错误并结束写任务，此后所有 Writer::send 都会失败。

pub fn send(&self, frame: Frame) -> Result<()>

编码并排队发送一帧，不等待实际写出。

Errors

• frame_too_large：编码后的帧超过 max_frame_size；
• runtime_unavailable：写任务已结束（Python 进程已退出或连接已关闭）。

Trait Implementations

impl Clone for Writer

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.