pub type AgentStreamTx = UnboundedSender<AgentStreamEvent>;
pub struct AgentStreamTx { /* private fields */ }