Struct DefaultRequestProcessor 

pub struct DefaultRequestProcessor<M, T, N, A = SimpleAgentInfo>
where
    M: AsyncMessageHandler + Send + Sync + 'static,
    T: AsyncTaskManager + Send + Sync + 'static,
    N: AsyncNotificationManager + Send + Sync + 'static,
    A: AgentInfoProvider + Send + Sync + 'static,
{ /* private fields */ }

Default implementation of a request processor that routes requests to business handlers

Implementations

impl<M, T, N, A> DefaultRequestProcessor<M, T, N, A>

where M: AsyncMessageHandler + Send + Sync + 'static, T: AsyncTaskManager + Send + Sync + 'static, N: AsyncNotificationManager + Send + Sync + 'static, A: AgentInfoProvider + Send + Sync + 'static,

pub fn new( message_handler: M, task_manager: T, notification_manager: N, agent_info: A, ) -> Self

Create a new request processor with the given handlers

impl<H, A> DefaultRequestProcessor<H, H, H, A>

where H: AsyncMessageHandler + AsyncTaskManager + AsyncNotificationManager + Send + Sync + 'static, A: AgentInfoProvider + Send + Sync + 'static,

pub fn with_handler(handler: H, agent_info: A) -> Self

Create a new request processor with a single handler that implements all traits

Trait Implementations

impl<M, T, N, A> AsyncA2ARequestProcessor for DefaultRequestProcessor<M, T, N, A>

where M: AsyncMessageHandler + Send + Sync + 'static, T: AsyncTaskManager + Send + Sync + 'static, N: AsyncNotificationManager + Send + Sync + 'static, A: AgentInfoProvider + Send + Sync + 'static,

fn process_raw_request<'life0, 'life1, 'async_trait>( &'life0 self, request: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<String, A2AError>> + Send + 'async_trait>>

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

Process a raw JSON-RPC request string

fn process_request<'life0, 'life1, 'async_trait>( &'life0 self, request: &'life1 A2ARequest, ) -> Pin<Box<dyn Future<Output = Result<JSONRPCResponse, A2AError>> + Send + 'async_trait>>

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

Process a parsed A2A request

impl<M, T, N, A> Clone for DefaultRequestProcessor<M, T, N, A>

where M: AsyncMessageHandler + Send + Sync + 'static + Clone, T: AsyncTaskManager + Send + Sync + 'static + Clone, N: AsyncNotificationManager + Send + Sync + 'static + Clone, A: AgentInfoProvider + Send + Sync + 'static + Clone,

fn clone(&self) -> DefaultRequestProcessor<M, T, N, A>

Returns a duplicate of the value.

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

Performs copy-assignment from source.