Struct A2aServiceClient 

pub struct A2aServiceClient<T> { /* private fields */ }

Client for this service.

Generic over T: ClientTransport. For gRPC (HTTP/2), use Http2Connection — it has honest poll_ready and composes with tower::balance for multi-connection load balancing. For Connect over HTTP/1.1 (or unknown protocol), use HttpClient.

Example (gRPC / HTTP/2)

use connectrpc::client::{Http2Connection, ClientConfig};
use connectrpc::Protocol;

let uri: http::Uri = "http://localhost:8080".parse()?;
let conn = Http2Connection::connect_plaintext(uri.clone()).await?.shared(1024);
let config = ClientConfig::new(uri).protocol(Protocol::Grpc);

let client = A2aServiceClient::new(conn, config);
let response = client.send_message(request).await?;

Example (Connect / HTTP/1.1 or ALPN)

use connectrpc::client::{HttpClient, ClientConfig};

let http = HttpClient::plaintext();  // cleartext http:// only
let config = ClientConfig::new("http://localhost:8080".parse()?);

let client = A2aServiceClient::new(http, config);
let response = client.send_message(request).await?;

Working with the response

Unary calls return UnaryResponse<OwnedView<FooView>>. The OwnedView derefs to the view, so field access is zero-copy:

let resp = client.send_message(request).await?.into_view();
let name: &str = resp.name;  // borrow into the response buffer

If you need the owned struct (e.g. to store or pass by value), use into_owned():

let owned = client.send_message(request).await?.into_owned();

Implementations

impl<T> A2aServiceClient<T>

where T: ClientTransport, <T::ResponseBody as Body>::Error: Display,

pub fn new(transport: T, config: ClientConfig) -> Self

Create a new client with the given transport and configuration.

pub fn config(&self) -> &ClientConfig

Get the client configuration.

pub fn config_mut(&mut self) -> &mut ClientConfig

Get a mutable reference to the client configuration.

pub async fn send_message( &self, request: SendMessageRequest, ) -> Result<UnaryResponse<OwnedView<SendMessageResponseView<'static>>>, ConnectError>

Call the SendMessage RPC. Sends a request to /lf.a2a.v1.A2AService/SendMessage.

pub async fn send_message_with_options( &self, request: SendMessageRequest, options: CallOptions, ) -> Result<UnaryResponse<OwnedView<SendMessageResponseView<'static>>>, ConnectError>

Call the SendMessage RPC with explicit per-call options. Options override ClientConfig defaults.

pub async fn send_streaming_message( &self, request: SendMessageRequest, ) -> Result<ServerStream<T::ResponseBody, StreamResponseView<'static>>, ConnectError>

Call the SendStreamingMessage RPC. Sends a request to /lf.a2a.v1.A2AService/SendStreamingMessage.

pub async fn send_streaming_message_with_options( &self, request: SendMessageRequest, options: CallOptions, ) -> Result<ServerStream<T::ResponseBody, StreamResponseView<'static>>, ConnectError>

Call the SendStreamingMessage RPC with explicit per-call options. Options override ClientConfig defaults.

pub async fn get_task( &self, request: GetTaskRequest, ) -> Result<UnaryResponse<OwnedView<TaskView<'static>>>, ConnectError>

Call the GetTask RPC. Sends a request to /lf.a2a.v1.A2AService/GetTask.

pub async fn get_task_with_options( &self, request: GetTaskRequest, options: CallOptions, ) -> Result<UnaryResponse<OwnedView<TaskView<'static>>>, ConnectError>

Call the GetTask RPC with explicit per-call options. Options override ClientConfig defaults.

pub async fn list_tasks( &self, request: ListTasksRequest, ) -> Result<UnaryResponse<OwnedView<ListTasksResponseView<'static>>>, ConnectError>

Call the ListTasks RPC. Sends a request to /lf.a2a.v1.A2AService/ListTasks.

pub async fn list_tasks_with_options( &self, request: ListTasksRequest, options: CallOptions, ) -> Result<UnaryResponse<OwnedView<ListTasksResponseView<'static>>>, ConnectError>

Call the ListTasks RPC with explicit per-call options. Options override ClientConfig defaults.

pub async fn cancel_task( &self, request: CancelTaskRequest, ) -> Result<UnaryResponse<OwnedView<TaskView<'static>>>, ConnectError>

Call the CancelTask RPC. Sends a request to /lf.a2a.v1.A2AService/CancelTask.

pub async fn cancel_task_with_options( &self, request: CancelTaskRequest, options: CallOptions, ) -> Result<UnaryResponse<OwnedView<TaskView<'static>>>, ConnectError>

Call the CancelTask RPC with explicit per-call options. Options override ClientConfig defaults.

pub async fn subscribe_to_task( &self, request: SubscribeToTaskRequest, ) -> Result<ServerStream<T::ResponseBody, StreamResponseView<'static>>, ConnectError>

Call the SubscribeToTask RPC. Sends a request to /lf.a2a.v1.A2AService/SubscribeToTask.

pub async fn subscribe_to_task_with_options( &self, request: SubscribeToTaskRequest, options: CallOptions, ) -> Result<ServerStream<T::ResponseBody, StreamResponseView<'static>>, ConnectError>

Call the SubscribeToTask RPC with explicit per-call options. Options override ClientConfig defaults.

pub async fn create_task_push_notification_config( &self, request: TaskPushNotificationConfig, ) -> Result<UnaryResponse<OwnedView<TaskPushNotificationConfigView<'static>>>, ConnectError>

Call the CreateTaskPushNotificationConfig RPC. Sends a request to /lf.a2a.v1.A2AService/CreateTaskPushNotificationConfig.

pub async fn create_task_push_notification_config_with_options( &self, request: TaskPushNotificationConfig, options: CallOptions, ) -> Result<UnaryResponse<OwnedView<TaskPushNotificationConfigView<'static>>>, ConnectError>

Call the CreateTaskPushNotificationConfig RPC with explicit per-call options. Options override ClientConfig defaults.

pub async fn get_task_push_notification_config( &self, request: GetTaskPushNotificationConfigRequest, ) -> Result<UnaryResponse<OwnedView<TaskPushNotificationConfigView<'static>>>, ConnectError>

Call the GetTaskPushNotificationConfig RPC. Sends a request to /lf.a2a.v1.A2AService/GetTaskPushNotificationConfig.

pub async fn get_task_push_notification_config_with_options( &self, request: GetTaskPushNotificationConfigRequest, options: CallOptions, ) -> Result<UnaryResponse<OwnedView<TaskPushNotificationConfigView<'static>>>, ConnectError>

Call the GetTaskPushNotificationConfig RPC with explicit per-call options. Options override ClientConfig defaults.

pub async fn list_task_push_notification_configs( &self, request: ListTaskPushNotificationConfigsRequest, ) -> Result<UnaryResponse<OwnedView<ListTaskPushNotificationConfigsResponseView<'static>>>, ConnectError>

Call the ListTaskPushNotificationConfigs RPC. Sends a request to /lf.a2a.v1.A2AService/ListTaskPushNotificationConfigs.

pub async fn list_task_push_notification_configs_with_options( &self, request: ListTaskPushNotificationConfigsRequest, options: CallOptions, ) -> Result<UnaryResponse<OwnedView<ListTaskPushNotificationConfigsResponseView<'static>>>, ConnectError>

Call the ListTaskPushNotificationConfigs RPC with explicit per-call options. Options override ClientConfig defaults.

pub async fn get_extended_agent_card( &self, request: GetExtendedAgentCardRequest, ) -> Result<UnaryResponse<OwnedView<AgentCardView<'static>>>, ConnectError>

Call the GetExtendedAgentCard RPC. Sends a request to /lf.a2a.v1.A2AService/GetExtendedAgentCard.

pub async fn get_extended_agent_card_with_options( &self, request: GetExtendedAgentCardRequest, options: CallOptions, ) -> Result<UnaryResponse<OwnedView<AgentCardView<'static>>>, ConnectError>

Call the GetExtendedAgentCard RPC with explicit per-call options. Options override ClientConfig defaults.

pub async fn delete_task_push_notification_config( &self, request: DeleteTaskPushNotificationConfigRequest, ) -> Result<UnaryResponse<OwnedView<EmptyView<'static>>>, ConnectError>

Call the DeleteTaskPushNotificationConfig RPC. Sends a request to /lf.a2a.v1.A2AService/DeleteTaskPushNotificationConfig.

pub async fn delete_task_push_notification_config_with_options( &self, request: DeleteTaskPushNotificationConfigRequest, options: CallOptions, ) -> Result<UnaryResponse<OwnedView<EmptyView<'static>>>, ConnectError>

Call the DeleteTaskPushNotificationConfig RPC with explicit per-call options. Options override ClientConfig defaults.

Trait Implementations

impl<T: Clone> Clone for A2aServiceClient<T>

fn clone(&self) -> A2aServiceClient<T>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.