Struct EchoHandler 

pub struct EchoHandler { /* private fields */ }

TEST FIXTURE — DO NOT WIRE INTO PRODUCTION.

EchoHandler is an unauthenticated, in-memory A2aHandler used by the crate’s own integration tests, the conformance suite, and the cargo klieo a2a-conformance CLI. It accepts every inbound SendMessage regardless of caller identity, advertises empty securitySchemes on its agent card, and stores tasks in process memory only.

Wiring this handler into an A2aServer outside a test context is a security bug — any caller reachable on the transport can submit tasks that are recorded as Completed.

Available only when the test-fixtures Cargo feature is enabled (or in cfg(test) builds of klieo-a2a itself).

Trait Implementations

impl A2aHandler for EchoHandler

fn send_message<'life0, 'life1, 'async_trait>( &'life0 self, _ctx: &'life1 RequestContext, params: SendMessageParams, ) -> Pin<Box<dyn Future<Output = Result<SendMessageResult, A2aError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Spec §9.4.1. ctx.caller is the verified identity (or None only when AllowAnonymous was wired). Implementations should reject None for mutating methods.

fn get_task<'life0, 'life1, 'async_trait>( &'life0 self, _ctx: &'life1 RequestContext, params: GetTaskParams, ) -> Pin<Box<dyn Future<Output = Result<Task, A2aError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Spec §9.4.3.

fn list_tasks<'life0, 'life1, 'async_trait>( &'life0 self, _ctx: &'life1 RequestContext, params: ListTasksParams, ) -> Pin<Box<dyn Future<Output = Result<ListTasksResult, A2aError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Spec §9.4.4.

fn cancel_task<'life0, 'life1, 'async_trait>( &'life0 self, _ctx: &'life1 RequestContext, params: CancelTaskParams, ) -> Pin<Box<dyn Future<Output = Result<Task, A2aError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Spec §9.4.5.

fn get_extended_agent_card<'life0, 'life1, 'async_trait>( &'life0 self, _ctx: &'life1 RequestContext, _params: GetExtendedAgentCardParams, ) -> Pin<Box<dyn Future<Output = Result<AgentCard, A2aError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Spec §9.4.11.

fn send_streaming_message<'life0, 'life1, 'async_trait>( &'life0 self, _ctx: &'life1 RequestContext, _params: SendMessageParams, ) -> Pin<Box<dyn Future<Output = Result<TaskEventStream, A2aError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Spec §9.4.2. Streaming variant — v0.0.2. Return a TaskEventStream to override the dispatcher’s default broadcast-derived stream; return A2aError::MethodNotFound to fall back to it.

fn subscribe_to_task<'life0, 'life1, 'async_trait>( &'life0 self, _ctx: &'life1 RequestContext, _params: SubscribeToTaskParams, ) -> Pin<Box<dyn Future<Output = Result<TaskEventStream, A2aError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Spec §9.4.6. v0.0.2. Return a TaskEventStream to override the dispatcher’s default broadcast-derived stream; return A2aError::MethodNotFound to fall back to it.

fn create_task_push_notification_config<'life0, 'life1, 'async_trait>( &'life0 self, _ctx: &'life1 RequestContext, _params: PushNotificationConfigParams, ) -> Pin<Box<dyn Future<Output = Result<PushNotificationConfig, A2aError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Spec §9.4.7. v0.0.2.

fn get_task_push_notification_config<'life0, 'life1, 'async_trait>( &'life0 self, _ctx: &'life1 RequestContext, _params: GetPushNotificationConfigParams, ) -> Pin<Box<dyn Future<Output = Result<PushNotificationConfig, A2aError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Spec §9.4.8. v0.0.2.

fn list_task_push_notification_configs<'life0, 'life1, 'async_trait>( &'life0 self, _ctx: &'life1 RequestContext, _params: ListPushNotificationConfigsParams, ) -> Pin<Box<dyn Future<Output = Result<ListPushNotificationConfigsResult, A2aError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Spec §9.4.9. v0.0.2.

fn delete_task_push_notification_config<'life0, 'life1, 'async_trait>( &'life0 self, _ctx: &'life1 RequestContext, _params: DeletePushNotificationConfigParams, ) -> Pin<Box<dyn Future<Output = Result<(), A2aError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Spec §9.4.10. v0.0.2.

fn is_idempotent(&self) -> bool

Returns true if all streaming invocations against this handler are safe to re-execute from the original payload — i.e. the result is deterministic OR duplicate execution has no business effect.

impl Default for EchoHandler

fn default() -> EchoHandler

Returns the “default value” for a type.