Trait EventSink 

pub trait EventSink: Send {
    // Required methods
    fn on_text(&mut self, text: &str);
    fn on_tool_call(&mut self, name: &str, arguments: &str);
    fn on_tool_result(&mut self, name: &str, result: &str, is_error: bool);
    fn on_confirmation_request(&mut self, prompt: &str) -> bool;

    // Provided methods
    fn on_turn_start(&mut self) { ... }
    fn on_command_started(&mut self, _command: &str) { ... }
    fn on_command_output(&mut self, _stream: &str, _chunk: &str) { ... }
    fn on_command_finished(
        &mut self,
        _success: bool,
        _exit_code: i32,
        _duration_ms: u64,
    ) { ... }
    fn on_preview_started(&mut self, _path: &str, _port: u16) { ... }
    fn on_preview_ready(&mut self, _url: &str, _port: u16) { ... }
    fn on_preview_failed(&mut self, _message: &str) { ... }
    fn on_preview_stopped(&mut self, _reason: &str) { ... }
    fn on_swarm_started(&mut self, _description: &str) { ... }
    fn on_swarm_progress(&mut self, _status: &str) { ... }
    fn on_swarm_finished(&mut self, _summary: &str) { ... }
    fn on_swarm_failed(&mut self, _message: &str) { ... }
    fn on_text_chunk(&mut self, _chunk: &str) { ... }
    fn on_task_plan(&mut self, _tasks: &[Task]) { ... }
    fn on_task_progress(
        &mut self,
        _task_id: u32,
        _completed: bool,
        _tasks: &[Task],
    ) { ... }
    fn on_clarification_request(
        &mut self,
        _request: &ClarificationRequest,
    ) -> ClarificationResponse { ... }
}

Event sink trait for different output targets (CLI, RPC, SDK).

Required Methods

fn on_text(&mut self, text: &str)

Called when the assistant produces text content.

fn on_tool_call(&mut self, name: &str, arguments: &str)

Called when a tool is about to be invoked.

fn on_tool_result(&mut self, name: &str, result: &str, is_error: bool)

Called when a tool returns a result.

fn on_confirmation_request(&mut self, prompt: &str) -> bool

Called when the agent needs user confirmation (L3 security). Returns true if the user approves.

Provided Methods

fn on_turn_start(&mut self)

Called at the start of each conversation turn (before any other events).

fn on_command_started(&mut self, _command: &str)

Called when a command tool starts execution.

fn on_command_output(&mut self, _stream: &str, _chunk: &str)

Called when a command tool emits incremental stdout/stderr output.

fn on_command_finished( &mut self, _success: bool, _exit_code: i32, _duration_ms: u64, )

Called when a command tool finishes execution.

fn on_preview_started(&mut self, _path: &str, _port: u16)

Called when preview server startup begins.

fn on_preview_ready(&mut self, _url: &str, _port: u16)

Called when preview server is ready.

fn on_preview_failed(&mut self, _message: &str)

Called when preview server startup fails.

fn on_preview_stopped(&mut self, _reason: &str)

Called when preview server stops.

fn on_swarm_started(&mut self, _description: &str)

Called when swarm delegation starts.

fn on_swarm_progress(&mut self, _status: &str)

Called with lightweight swarm progress updates.

fn on_swarm_finished(&mut self, _summary: &str)

Called when swarm delegation finishes with a summary.

fn on_swarm_failed(&mut self, _message: &str)

Called when swarm delegation fails or falls back.

fn on_text_chunk(&mut self, _chunk: &str)

Called for streaming text chunks.

fn on_task_plan(&mut self, _tasks: &[Task])

Called when a task plan is generated. (Phase 2)

fn on_task_progress(&mut self, _task_id: u32, _completed: bool, _tasks: &[Task])

Called when a task’s status changes. (Phase 2) tasks contains the full updated task list for progress rendering.

fn on_clarification_request( &mut self, _request: &ClarificationRequest, ) -> ClarificationResponse

Called when the agent is about to stop and wants user clarification. Returns Continue(hint) to keep going or Stop to terminate.

Implementors

impl EventSink for RunModeEventSink

impl EventSink for SilentEventSink

impl EventSink for TerminalEventSink