Struct LoopbackChannel 

pub struct LoopbackChannel { /* private fields */ }

Headless channel bridging an A2A TaskProcessor with the agent loop.

Implementations

impl LoopbackChannel

pub fn pair(buffer: usize) -> (Self, LoopbackHandle)

Create a linked (LoopbackChannel, LoopbackHandle) pair.

Trait Implementations

impl Channel for LoopbackChannel

fn supports_exit(&self) -> bool

Whether /exit and /quit commands should terminate the agent loop.

async fn recv(&mut self) -> Result<Option<ChannelMessage>, ChannelError>

Receive the next message. Returns None on EOF or shutdown.

async fn send(&mut self, text: &str) -> Result<(), ChannelError>

Send a text response.

async fn send_chunk(&mut self, chunk: &str) -> Result<(), ChannelError>

Send a partial chunk of streaming response.

async fn flush_chunks(&mut self) -> Result<(), ChannelError>

Flush any buffered chunks.

async fn send_status(&mut self, text: &str) -> Result<(), ChannelError>

Send a status label (shown as spinner text in TUI). No-op by default.

async fn send_thinking_chunk(&mut self, chunk: &str) -> Result<(), ChannelError>

Send a thinking/reasoning token chunk. No-op by default.

async fn send_tool_start( &mut self, event: ToolStartEvent, ) -> Result<(), ChannelError>

Announce that a tool call is starting.

async fn send_tool_output( &mut self, event: ToolOutputEvent, ) -> Result<(), ChannelError>

Send a complete tool output with optional diff and filter stats atomically.

async fn confirm(&mut self, _prompt: &str) -> Result<bool, ChannelError>

Request user confirmation for a destructive action. Returns true if confirmed. Default: auto-confirm (for headless/test scenarios).

async fn send_stop_hint(&mut self, hint: StopHint) -> Result<(), ChannelError>

Signal the non-default stop reason to the consumer before flushing.

async fn send_usage( &mut self, input_tokens: u64, output_tokens: u64, context_window: u64, ) -> Result<(), ChannelError>

Send token usage after an LLM call. No-op by default.

fn try_recv(&mut self) -> Option<ChannelMessage>

Non-blocking receive. Returns None if no message is immediately available.

fn send_typing( &mut self, ) -> impl Future<Output = Result<(), ChannelError>> + Send

Send a typing indicator. No-op by default.

fn send_queue_count( &mut self, _count: usize, ) -> impl Future<Output = Result<(), ChannelError>> + Send

Notify channel of queued message count. No-op by default.

fn send_diff( &mut self, _diff: DiffData, ) -> impl Future<Output = Result<(), ChannelError>> + Send

Send diff data for a tool result. No-op by default (TUI overrides).

fn elicit( &mut self, _request: ElicitationRequest, ) -> impl Future<Output = Result<ElicitationResponse, ChannelError>> + Send

Request structured input from the user for an MCP elicitation.