Enum AnyChannel 

pub enum AnyChannel {
    Cli(CliChannel),
    JsonCli(JsonCliChannel),
    Telegram(TelegramChannel),
}

Enum dispatch for runtime channel selection.

AnyChannel implements Channel by forwarding every method call to the active variant through a private macro. The binary picks a variant at startup; the rest of the codebase never needs to be generic over the channel type.

Variants

• Cli — reads from stdin and writes to stdout via CliChannel.
• JsonCli — reads from stdin and emits JSONL events to stdout via JsonCliChannel.
• Telegram — Telegram Bot API adapter via crate::telegram::TelegramChannel.
• Discord (feature discord) — Discord gateway adapter.
• Slack (feature slack) — Slack Events API adapter.

Examples

use zeph_channels::{AnyChannel, CliChannel};
use zeph_core::channel::Channel;

let mut ch = AnyChannel::Cli(CliChannel::new());
// Send a message regardless of the underlying channel.
ch.send("Hello!").await.unwrap();

Variants

Cli(CliChannel)

JsonCli(JsonCliChannel)

Telegram(TelegramChannel)

Trait Implementations

impl Channel for AnyChannel

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_typing(&mut self) -> Result<(), ChannelError>

Send a typing indicator. No-op by default.

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 elicit( &mut self, request: ElicitationRequest, ) -> Result<ElicitationResponse, ChannelError>

Request structured input from the user for an MCP elicitation.

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

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

fn supports_exit(&self) -> bool

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

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_queue_count(&mut self, count: usize) -> Result<(), ChannelError>

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

async fn send_diff(&mut self, diff: DiffData) -> Result<(), ChannelError>

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

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 send_thinking_chunk(&mut self, chunk: &str) -> Result<(), ChannelError>

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

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.

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

Announce that a tool call is starting.

impl Debug for AnyChannel

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.