Struct OutChannel 

pub struct OutChannel { /* private fields */ }

Implementations

impl OutChannel

pub fn new(sender: Option<Sender<Notification>>, name: String) -> Self

Trait Implementations

impl NotificationHandler for OutChannel

fn get_outgoing_channel(&self) -> &Option<Sender<Notification>>

fn get_channel_name(&self) -> &String

async fn notify(&self, content: NotificationContent) -> bool

Send a notification with the given content.

fn forward_notifications(&self, from_channel: Receiver<Notification>)

Forward notifications from an external receiver into this agent’s notification output channel.

fn forward_multiple_notifications<I>(&self, channels: I)

where I: IntoIterator<Item = Receiver<Notification>>,

Merge any number of Receiver<Notification> streams into one, and forward all messages into this agent’s notification output channel.

async fn notify_done(&self, success: Success, resp: Response) -> bool

async fn notify_prompt_request(&self, req: ChatRequest) -> bool

async fn notify_poompt_success(&self, resp: ChatResponse) -> bool

async fn notify_prompt_error(&self, error_message: String) -> bool

async fn notify_tool_request(&self, tool_call: ToolCall) -> bool

async fn notify_tool_success(&self, tool_result: String) -> bool

async fn notify_tool_error(&self, error_message: String) -> bool

async fn notify_token(&self, token: Token) -> bool

async fn notify_mcp_tool_notification(&self, notification: String) -> bool

async fn notify_custom(&self, custom_val: Value) -> bool