Struct Client 

pub struct Client { /* private fields */ }

A2A protocol client.

Wraps a Transport and applies CallInterceptors before/after each call.

Implementations

impl Client

pub fn new(transport: Box<dyn Transport>) -> Client

Creates a new client wrapping the given transport.

pub fn from_url(base_url: impl Into<String>) -> Result<Client, A2AError>

Creates a client from a base URL using JsonRpcTransport.

pub fn with_config(self, config: ClientConfig) -> Client

Sets client configuration.

pub fn with_interceptor( self, interceptor: impl CallInterceptor + 'static, ) -> Client

Adds a call interceptor.

pub fn with_interceptor_arc( self, interceptor: Arc<dyn CallInterceptor>, ) -> Client

Adds a pre-built call interceptor from an Arc.

pub fn set_card(&self, card: AgentCard)

Caches an agent card for capability checks.

pub fn card(&self) -> Option<AgentCard>

Returns the cached agent card, if any.

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

Sends a message (non-streaming).

pub async fn send_streaming_message( &self, req: &SendMessageRequest, ) -> Result<Pin<Box<dyn Stream<Item = Result<StreamResponse, A2AError>> + Send>>, A2AError>

Sends a message with streaming response.

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

Retrieves a task.

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

Lists tasks.

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

Cancels a task.

pub async fn subscribe_to_task( &self, req: &SubscribeToTaskRequest, ) -> Result<Pin<Box<dyn Stream<Item = Result<StreamResponse, A2AError>> + Send>>, A2AError>

Subscribes to task updates.

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

Retrieves the public agent card.

Returns the cached version if available and the agent doesn’t support extended cards.

pub async fn destroy(&self)

Releases transport resources.