Struct EventBus 

pub struct EventBus { /* private fields */ }

A cloneable broadcast bus for agent events.

All components publish to the same bus; external observers subscribe independently. Cloning is cheap — all clones share the same underlying channel.

Example

use agentix::EventBus;

let bus = EventBus::new(512);

// Attach a custom observer
bus.tap(|msg| async move {
    println!("{msg:?}");
});

// Raw subscriber (e.g. for a WebSocket handler)
let mut rx = bus.subscribe();

Implementations

impl EventBus

pub fn new(capacity: usize) -> Self

pub fn send(&self, msg: Msg)

Broadcast a message to all current subscribers. Silently drops the message if there are no subscribers.

pub fn subscribe(&self) -> Receiver<Msg>

Subscribe to future messages.

pub fn subscribe_assembled(&self) -> impl Stream<Item = Msg> + 'static

Subscribe to future messages, folding streaming fragments into complete events.

Concretely:

• Multiple Msg::Token chunks are buffered and emitted as a single Token(full_text) just before the Msg::Done that ends the turn.
• Multiple Msg::Reasoning chunks are folded the same way.
• All other variants (ToolCall, ToolResult, Done, User, …) pass through unchanged.

This gives downstream nodes the same view a non-streaming provider would produce — same variant names, just assembled content.

pub fn tap<F, Fut>(&self, f: F)

where F: Fn(Msg) -> Fut + Send + 'static, Fut: Future<Output = ()> + Send + 'static,

Spawn a background task that calls f for every bus message.

The task runs until the bus is dropped or the receiver lags too far behind (lagged messages are silently skipped).

Trait Implementations

impl Clone for EventBus

fn clone(&self) -> EventBus

Returns a duplicate of the value.

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

Performs copy-assignment from source.