Struct BufferedSink 

pub struct BufferedSink { /* private fields */ }

基于大缓冲队列的 StreamSink 实现。

用于 Agent 层：将 StreamChunk 推入队列， 由 Forward Task 异步消费并转发到 mpsc channel。

LLMNode
   ↓ emit() — O(1), 固定成本
BufferedSink (large buffer mpsc)
   ↓
Forward Task (spawn)
   ↓
mpsc::Sender<StreamChunk> (bounded, backpressure)
   ↓
Consumer

Implementations

impl BufferedSink

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

创建 BufferedSink（无界队列）。

取消机制负责清理：消费者离开 → cancel → Node 停止。

Trait Implementations

impl Clone for BufferedSink

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl StreamSink for BufferedSink

fn emit(&self, chunk: StreamChunk)

发射一个数据面事件。