Struct StreamEmitter 

pub struct StreamEmitter { /* private fields */ }

数据面发射器。

封装 mpsc::Sender，提供统一的发射接口。

Implementations

impl StreamEmitter

pub fn new(tx: Sender<StreamChunk>) -> Self

创建新的 StreamEmitter。

pub fn emit(&self, chunk: StreamChunk)

发射数据面事件。

pub async fn emit_async( &self, chunk: StreamChunk, ) -> Result<(), TrySendError<StreamChunk>>

发射数据面事件（异步，可能阻塞）。

pub fn sender(&self) -> Sender<StreamChunk>

获取底层 Sender 的 clone（用于子组件）。

Trait Implementations

impl Clone for StreamEmitter

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.