Struct EventEmitter 

pub struct EventEmitter { /* private fields */ }

Event emitter for sending events to multiple receivers

Implementations

impl EventEmitter

pub fn new() -> Self

Create a new emitter

pub fn with_handler(handler: EventHandler) -> Self

Create with an event handler

pub fn subscribe(&mut self) -> UnboundedReceiver<WorkflowEvent>

Subscribe to events

pub fn emit(&self, event: WorkflowEvent)

Emit an event

pub fn workflow_started(&self, workflow_id: &str, workflow_type: WorkflowType)

Emit workflow started event

pub fn workflow_completed( &self, workflow_id: &str, status: StreamingStatus, duration_ms: u64, )

Emit workflow completed event

pub fn workflow_failed(&self, workflow_id: &str, error: &str)

Emit workflow failed event

pub fn node_started(&self, node_id: &str, node_type: StreamingNodeType)

Emit node started event

pub fn node_completed( &self, node_id: &str, duration_ms: u64, state_changes: Vec<String>, )

Emit node completed event

pub fn token_delta( &self, token: &str, node_id: Option<&str>, agent_id: Option<&str>, )

Emit token delta event

pub fn agent_handoff(&self, from: &str, to: &str, reason: &str)

Emit handoff event

Trait Implementations

impl Default for EventEmitter

fn default() -> Self

Returns the “default value” for a type.