Struct DefaultMessageHandler 

pub struct DefaultMessageHandler<T>
where
    T: AsyncTaskManager + Send + Sync + 'static,
{ /* private fields */ }

Default message handler that processes messages and delegates to task manager

Implementations

impl<T> DefaultMessageHandler<T>

where T: AsyncTaskManager + Send + Sync + 'static,

pub fn new(task_manager: T) -> Self

Create a new message handler with the given task manager

Trait Implementations

impl<T> AsyncMessageHandler for DefaultMessageHandler<T>

where T: AsyncTaskManager + Send + Sync + 'static,

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<T> Clone for DefaultMessageHandler<T>

where T: AsyncTaskManager + Send + Sync + 'static + Clone,

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

Returns a duplicate of the value.

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

Performs copy-assignment from source.