Trait AsyncMessageHandler 

pub trait AsyncMessageHandler: Send + Sync {
    // Required method
    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;

    // Provided methods
    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 { ... }
    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 { ... }
    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 { ... }
}

An async trait for handling message processing operations

Required Methods

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

Provided Methods

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

Implementors

impl<T> AsyncMessageHandler for DefaultMessageHandler<T>

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