Struct EventStream 

pub struct EventStream { /* private fields */ }

Event stream with broadcast capability for real-time subscribers

Implementations

impl EventStream

pub fn new() -> Self

Create a new event stream with specified channel capacity

pub fn with_capacity(capacity: usize) -> Self

Create event stream with custom channel capacity

pub fn append( &self, event_type: EventType, workflow_id: WorkflowId, data: JsonValue, ) -> JoinHandle<Event>

Append a new event and broadcast to all subscribers

Events are emitted asynchronously in a spawned task to avoid blocking agent execution. Returns a JoinHandle that can be awaited if the caller needs to ensure the event was processed or needs the Event object.

Examples

use agent_runtime::event::{EventStream, EventType};
use serde_json::json;

let stream = EventStream::new();

// Fire and forget (most common)
stream.append(EventType::AgentInitialized, "workflow_1".to_string(), json!({}));

// Wait for event if needed
let event = stream.append(EventType::AgentCompleted, "workflow_1".to_string(), json!({}))
    .await
    .unwrap();

pub fn append_with_parent( &self, event_type: EventType, workflow_id: WorkflowId, parent_workflow_id: Option<WorkflowId>, data: JsonValue, ) -> JoinHandle<Event>

Append event with optional parent workflow ID

Events are emitted asynchronously to avoid blocking execution. Returns a JoinHandle that resolves to the created Event.

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

Subscribe to real-time event stream Returns a receiver that will get all future events

pub fn from_offset(&self, offset: EventOffset) -> Vec<Event>

Get events from a specific offset (for replay)

pub fn all(&self) -> Vec<Event>

Get all events

pub fn len(&self) -> usize

Get event count

pub fn is_empty(&self) -> bool

pub fn current_offset(&self) -> EventOffset

Get the current offset (next event will have this offset)

Trait Implementations

impl Clone for EventStream

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for EventStream

fn default() -> Self

Returns the “default value” for a type.