Struct A2aClient 

pub struct A2aClient { /* private fields */ }

Implementations

impl A2aClient

pub fn new(client: Client) -> Self

pub fn with_security(self, require_tls: bool, ssrf_protection: bool) -> Self

pub async fn send_message( &self, endpoint: &str, params: SendMessageParams, token: Option<&str>, ) -> Result<Task, A2aError>

Errors

Returns A2aError on network, JSON, or JSON-RPC errors.

pub async fn stream_message( &self, endpoint: &str, params: SendMessageParams, token: Option<&str>, ) -> Result<TaskEventStream, A2aError>

Errors

Returns A2aError on network failure or if the SSE connection cannot be established.

pub async fn get_task( &self, endpoint: &str, params: TaskIdParams, token: Option<&str>, ) -> Result<Task, A2aError>

Errors

Returns A2aError on network, JSON, or JSON-RPC errors.

pub async fn cancel_task( &self, endpoint: &str, params: TaskIdParams, token: Option<&str>, ) -> Result<Task, A2aError>

Errors

Returns A2aError on network, JSON, or JSON-RPC errors.