Struct EventHelper 

pub struct EventHelper;

Helper for managing event emissions

Implementations

impl EventHelper

pub async fn send(tx: &Option<Sender<Event>>, event: Event)

Send an event if sender is available

pub async fn send_task_started( tx: &Option<Sender<Event>>, sub_id: SubmissionId, actor_id: ActorID, actor_name: String, task_description: String, )

Send task started event

pub async fn send_task_completed( tx: &Option<Sender<Event>>, sub_id: SubmissionId, actor_id: ActorID, actor_name: String, result: String, )

Send task started event

pub async fn send_task_completed_value( tx: &Option<Sender<Event>>, sub_id: SubmissionId, actor_id: ActorID, actor_name: String, result: &Value, ) -> Result<(), Error>

Send task completed event with a JSON value result

pub async fn send_task_error( tx: &Option<Sender<Event>>, sub_id: SubmissionId, actor_id: ActorID, error: String, )

Send task error event

pub async fn abort_run_from_hook( tx: &Option<Sender<Event>>, sub_id: SubmissionId, actor_id: ActorID, ) -> RunnableAgentError

Emit TaskError for a hook abort and return RunnableAgentError::Abort.

pub async fn map_executor_stream_item<T, E>( tx: &Option<Sender<Event>>, sub_id: SubmissionId, actor_id: ActorID, result: Result<T, E>, ) -> Result<T, RunnableAgentError>

where E: Into<RunnableAgentError>,

Map an executor stream item to RunnableAgentError, emitting TaskError on failure.

pub async fn send_turn_started( tx: &Option<Sender<Event>>, sub_id: SubmissionId, actor_id: ActorID, turn_number: usize, max_turns: usize, )

Send turn started event

pub async fn send_turn_completed( tx: &Option<Sender<Event>>, sub_id: SubmissionId, actor_id: ActorID, turn_number: usize, final_turn: bool, )

Send turn completed event

pub async fn send_stream_chunk( tx: &Option<Sender<Event>>, sub_id: SubmissionId, chunk: LlmStreamChunk, )

Send stream chunk event

pub async fn send_stream_tool_call( tx: &Option<Sender<Event>>, sub_id: SubmissionId, tool_call: Value, )

Send stream tool call event

pub async fn send_stream_complete( tx: &Option<Sender<Event>>, sub_id: SubmissionId, )

Send stream complete event

pub async fn send_code_execution_started( tx: &Option<Sender<Event>>, sub_id: SubmissionId, actor_id: ActorID, execution_id: String, language: String, source: String, )

pub async fn send_code_execution_console( tx: &Option<Sender<Event>>, sub_id: SubmissionId, actor_id: ActorID, execution_id: String, message: String, )

pub async fn send_code_execution_completed( tx: &Option<Sender<Event>>, sub_id: SubmissionId, actor_id: ActorID, execution_id: String, result: Value, duration_ms: u64, )

pub async fn send_code_execution_failed( tx: &Option<Sender<Event>>, sub_id: SubmissionId, actor_id: ActorID, execution_id: String, error: String, duration_ms: u64, )