Struct StreamHub 

pub struct StreamHub { /* private fields */ }

扇出总线 — 将每个 emit 广播到所有注册的 sinks。

ParallelNode 的子分支 clone 父级的 Arc<StreamHub>， 子分支的 emit 自动汇聚到同一个消费者集合。

ExecutionEngine
    │
    ├── StreamHub (fan-out bus)
    │     ├── CLI sink
    │     ├── Trace sink
    │     └── AgentEvent sink
    │
    └── Parallel 子分支 clone Arc<StreamHub>
          ├── Branch A → emit → → StreamHub → all sinks
          └── Branch B → emit → → StreamHub → all sinks

StreamSink 不要求 Debug，故 StreamHub 也不 derive Debug。

Implementations

impl StreamHub

pub fn new() -> Self

pub fn add_sink(&mut self, sink: Arc<dyn StreamSink>)

注册一个 sink。

pub fn from_sink(sink: Arc<dyn StreamSink>) -> Self

从单个 sink 创建 StreamHub（便捷构造）。

pub fn is_empty(&self) -> bool

是否为空（无 sink）。

Trait Implementations

impl Clone for StreamHub

fn clone(&self) -> Self

Clone 只克隆 sink 列表的 Arc 引用（浅拷贝）。

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

Performs copy-assignment from source.

impl StreamSink for StreamHub

fn emit(&self, chunk: StreamChunk)

发射一个数据面事件。