Struct ChannelReporter 

pub struct ChannelReporter { /* private fields */ }

Reporter adapter that forwards events over a channel.

Use this when you need expensive or async event processing without blocking the agent loop. The receiving end can live on a dedicated thread or async task.

Example

use agentkit_reporting::ChannelReporter;

let (reporter, rx) = ChannelReporter::pair();

// Spawn a consumer on another thread.
std::thread::spawn(move || {
    while let Ok(event) = rx.recv() {
        println!("{event:?}");
    }
});

// `reporter` implements `LoopObserver` — hand it to the agent loop.

Implementations

impl ChannelReporter

pub fn new(sender: Sender<AgentEvent>) -> Self

Creates a ChannelReporter from an existing sender.

pub fn pair() -> (Self, Receiver<AgentEvent>)

Creates a ChannelReporter together with the receiving end of the channel.

Trait Implementations

impl FallibleObserver for ChannelReporter

fn try_handle_event(&self, event: &AgentEvent) -> Result<(), ReportError>

Process an event, returning an error if something goes wrong. Implementations store mutable state behind interior mutability so the wrapper can be shared as Arc<dyn LoopObserver>.

impl LoopObserver for ChannelReporter

fn handle_event(&self, event: AgentEvent)

Called synchronously for every AgentEvent emitted by the loop driver. Observers store mutable state behind interior mutability (Mutex, atomics, channels) so the driver can share an Arc<dyn LoopObserver> across reusable Agent starts.