Struct A2AClient 

pub struct A2AClient<T: Transport> { /* private fields */ }

High-level A2A client wrapping a transport with middleware.

Implementations

impl<T: Transport> A2AClient<T>

pub fn new(transport: T) -> Self

pub fn with_interceptors( self, interceptors: Vec<Arc<dyn CallInterceptor>>, ) -> Self

pub async fn send_message( &self, req: &SendMessageRequest, ) -> Result<SendMessageResponse, A2AError>

pub async fn send_streaming_message( &self, req: &SendMessageRequest, ) -> Result<BoxStream<'static, Result<StreamResponse, A2AError>>, A2AError>

pub async fn get_task(&self, req: &GetTaskRequest) -> Result<Task, A2AError>

pub async fn list_tasks( &self, req: &ListTasksRequest, ) -> Result<ListTasksResponse, A2AError>

pub async fn cancel_task( &self, req: &CancelTaskRequest, ) -> Result<Task, A2AError>

pub async fn subscribe_to_task( &self, req: &SubscribeToTaskRequest, ) -> Result<BoxStream<'static, Result<StreamResponse, A2AError>>, A2AError>

pub async fn create_push_config( &self, req: &TaskPushNotificationConfig, ) -> Result<TaskPushNotificationConfig, A2AError>

pub async fn get_push_config( &self, req: &GetTaskPushNotificationConfigRequest, ) -> Result<TaskPushNotificationConfig, A2AError>

pub async fn list_push_configs( &self, req: &ListTaskPushNotificationConfigsRequest, ) -> Result<ListTaskPushNotificationConfigsResponse, A2AError>

pub async fn delete_push_config( &self, req: &DeleteTaskPushNotificationConfigRequest, ) -> Result<(), A2AError>

pub async fn get_extended_agent_card( &self, req: &GetExtendedAgentCardRequest, ) -> Result<AgentCard, A2AError>

pub async fn destroy(&self) -> Result<(), A2AError>

Trait Implementations

impl<T: Transport> SendMessageExt for A2AClient<T>

fn send_text<'life0, 'async_trait>( &'life0 self, text: impl 'async_trait + Into<String> + Send, ) -> Pin<Box<dyn Future<Output = Result<SendMessageResponse, A2AError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,