pub trait RequestHandler:
Send
+ Sync
+ 'static {
// Required methods
fn send_message<'life0, 'life1, 'async_trait>(
&'life0 self,
params: &'life1 ServiceParams,
req: SendMessageRequest,
) -> Pin<Box<dyn Future<Output = Result<SendMessageResponse, A2AError>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait;
fn send_streaming_message<'life0, 'life1, 'async_trait>(
&'life0 self,
params: &'life1 ServiceParams,
req: SendMessageRequest,
) -> Pin<Box<dyn Future<Output = Result<BoxStream<'static, Result<StreamResponse, A2AError>>, A2AError>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait;
fn get_task<'life0, 'life1, 'async_trait>(
&'life0 self,
params: &'life1 ServiceParams,
req: GetTaskRequest,
) -> Pin<Box<dyn Future<Output = Result<Task, A2AError>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait;
fn list_tasks<'life0, 'life1, 'async_trait>(
&'life0 self,
params: &'life1 ServiceParams,
req: ListTasksRequest,
) -> Pin<Box<dyn Future<Output = Result<ListTasksResponse, A2AError>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait;
fn cancel_task<'life0, 'life1, 'async_trait>(
&'life0 self,
params: &'life1 ServiceParams,
req: CancelTaskRequest,
) -> Pin<Box<dyn Future<Output = Result<Task, A2AError>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait;
fn subscribe_to_task<'life0, 'life1, 'async_trait>(
&'life0 self,
params: &'life1 ServiceParams,
req: SubscribeToTaskRequest,
) -> Pin<Box<dyn Future<Output = Result<BoxStream<'static, Result<StreamResponse, A2AError>>, A2AError>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait;
fn create_push_config<'life0, 'life1, 'async_trait>(
&'life0 self,
params: &'life1 ServiceParams,
req: TaskPushNotificationConfig,
) -> Pin<Box<dyn Future<Output = Result<TaskPushNotificationConfig, A2AError>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait;
fn get_push_config<'life0, 'life1, 'async_trait>(
&'life0 self,
params: &'life1 ServiceParams,
req: GetTaskPushNotificationConfigRequest,
) -> Pin<Box<dyn Future<Output = Result<TaskPushNotificationConfig, A2AError>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait;
fn list_push_configs<'life0, 'life1, 'async_trait>(
&'life0 self,
params: &'life1 ServiceParams,
req: ListTaskPushNotificationConfigsRequest,
) -> Pin<Box<dyn Future<Output = Result<ListTaskPushNotificationConfigsResponse, A2AError>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait;
fn delete_push_config<'life0, 'life1, 'async_trait>(
&'life0 self,
params: &'life1 ServiceParams,
req: DeleteTaskPushNotificationConfigRequest,
) -> Pin<Box<dyn Future<Output = Result<(), A2AError>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait;
fn get_extended_agent_card<'life0, 'life1, 'async_trait>(
&'life0 self,
params: &'life1 ServiceParams,
req: GetExtendedAgentCardRequest,
) -> Pin<Box<dyn Future<Output = Result<AgentCard, A2AError>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait;
}Expand description
Transport-agnostic request handler interface.
This is the core interface consumed by all protocol bindings
(JSON-RPC, REST, gRPC). The DefaultRequestHandler provides a
standard implementation that orchestrates task lifecycle, storage,
and executor dispatch.