Struct ResponderMessageHandler 

pub struct ResponderMessageHandler { /* private fields */ }

A message handler that owns task-lifecycle plumbing and streaming announcements, delegating the reply to an injected Responder.

Holds its ports as Arc<dyn …> trait objects (injected at the composition edge), so the handler carries no generic parameter. Because it holds both the lifecycle and streaming ports it is a host for the TaskStatusBroadcast capability mixin.

Implementations

impl ResponderMessageHandler

pub fn new( task_lifecycle: impl AsyncTaskLifecycle + 'static, streaming: impl AsyncStreamingHandler + 'static, push_notifier: impl AsyncPushNotifier + 'static, responder: impl Responder + 'static, ) -> Self

Create a handler with a custom Responder.

The lifecycle, streaming, and push-notifier ports are accepted separately so the handler depends only on the capabilities it uses; at the composition edge the streaming and push ports typically come from a dedicated streaming adapter and the store’s push_notifier().

pub fn echo( task_lifecycle: impl AsyncTaskLifecycle + 'static, streaming: impl AsyncStreamingHandler + 'static, push_notifier: impl AsyncPushNotifier + 'static, ) -> Self

Create the reference echo handler (EchoResponder).

Trait Implementations

impl AsyncMessageHandler for ResponderMessageHandler

fn process_message<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, task_id: &'life1 str, message: &'life2 Message, session_id: Option<&'life3 str>, ) -> Pin<Box<dyn Future<Output = Result<Task, A2AError>> + Send + 'async_trait>>

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

Process a message for a specific task

fn validate_message<'life0, 'life1, 'async_trait>( &'life0 self, message: &'life1 Message, ) -> Pin<Box<dyn Future<Output = Result<(), A2AError>> + Send + 'async_trait>>

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

Validate a message before processing

fn transform_message<'life0, 'async_trait>( &'life0 self, message: Message, ) -> Pin<Box<dyn Future<Output = Result<Message, A2AError>> + Send + 'async_trait>>

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

Transform a message before processing (e.g., for content filtering)

fn handle_message_flow<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, task_id: &'life1 str, message: Message, session_id: Option<&'life2 str>, ) -> Pin<Box<dyn Future<Output = Result<Task, A2AError>> + Send + 'async_trait>>

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

Handle message processing with validation and transformation

impl Clone for ResponderMessageHandler

fn clone(&self) -> ResponderMessageHandler

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl HasPushNotifier for ResponderMessageHandler

fn push_notifier(&self) -> &dyn AsyncPushNotifier

impl HasStreaming for ResponderMessageHandler

fn streaming(&self) -> &dyn AsyncStreamingHandler

impl HasTaskLifecycle for ResponderMessageHandler

fn lifecycle(&self) -> &dyn AsyncTaskLifecycle