Struct JsonRpcTransport 

pub struct JsonRpcTransport { /* private fields */ }

Available on crate feature client only.

JSON-RPC 2.0 transport for the A2A protocol.

Handles both synchronous (JSON response) and streaming (SSE) requests. SSE events are wrapped in JSON-RPC response envelopes by the server, and this transport unwraps them into protocol Events.

Implementations

impl JsonRpcTransport

pub fn new(config: TransportConfig) -> Result<Self>

Creates a new transport with the given configuration.

pub fn from_url(base_url: impl Into<String>) -> Result<Self>

Creates a transport from a base URL with default settings.

Trait Implementations

impl Clone for JsonRpcTransport

fn clone(&self) -> JsonRpcTransport

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for JsonRpcTransport

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Transport for JsonRpcTransport

fn send_message<'a>( &'a self, params: &'a MessageSendParams, ) -> Pin<Box<dyn Future<Output = Result<SendMessageResult>> + Send + 'a>>

Sends a message (non-streaming). Corresponds to message/send.

fn send_message_stream<'a>( &'a self, params: &'a MessageSendParams, ) -> Pin<Box<dyn Future<Output = Result<EventStream>> + Send + 'a>>

Sends a message with streaming response. Corresponds to message/stream.

fn get_task<'a>( &'a self, params: &'a TaskQueryParams, ) -> Pin<Box<dyn Future<Output = Result<Task>> + Send + 'a>>

Retrieves a task. Corresponds to tasks/get.

fn list_tasks<'a>( &'a self, params: &'a ListTasksRequest, ) -> Pin<Box<dyn Future<Output = Result<ListTasksResponse>> + Send + 'a>>

Lists tasks. Corresponds to tasks/list.

fn cancel_task<'a>( &'a self, params: &'a TaskIdParams, ) -> Pin<Box<dyn Future<Output = Result<Task>> + Send + 'a>>

Cancels a task. Corresponds to tasks/cancel.

fn resubscribe<'a>( &'a self, params: &'a TaskIdParams, ) -> Pin<Box<dyn Future<Output = Result<EventStream>> + Send + 'a>>

Resubscribes to a task’s event stream. Corresponds to tasks/resubscribe.

fn set_task_push_config<'a>( &'a self, params: &'a TaskPushConfig, ) -> Pin<Box<dyn Future<Output = Result<TaskPushConfig>> + Send + 'a>>

Sets push notification config for a task.

fn get_task_push_config<'a>( &'a self, params: &'a GetTaskPushConfigParams, ) -> Pin<Box<dyn Future<Output = Result<TaskPushConfig>> + Send + 'a>>

Gets push notification config for a task.

fn list_task_push_config<'a>( &'a self, params: &'a ListTaskPushConfigParams, ) -> Pin<Box<dyn Future<Output = Result<Vec<TaskPushConfig>>> + Send + 'a>>

Lists push notification configs for a task.

fn delete_task_push_config<'a>( &'a self, params: &'a DeleteTaskPushConfigParams, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'a>>

Deletes push notification config for a task.

fn get_agent_card( &self, ) -> Pin<Box<dyn Future<Output = Result<AgentCard>> + Send + '_>>

Retrieves the agent card.

fn destroy(&self) -> Pin<Box<dyn Future<Output = ()> + Send + '_>>

Releases any resources held by the transport.