Struct InMemoryQueryBus 

pub struct InMemoryQueryBus { /* private fields */ }

基于内存的 QueryBus 实现

• 通过 TypeId 注册不同 Query 对应的 Handler
• 以类型擦除方式调度，并在调用端进行结果还原

Implementations

impl InMemoryQueryBus

pub fn new() -> Self

pub fn register<Q, R, H>(&self, handler: Arc<H>) -> Result<(), AppError>

where Q: Send + 'static, R: Send + 'static, H: QueryHandler<Q, R> + Send + Sync + 'static,

注册查询处理器

impl InMemoryQueryBus

pub fn registered_queries(&self) -> Vec<&'static str>

获取已注册的查询类型名列表（只读视图）

Trait Implementations

impl Default for InMemoryQueryBus

fn default() -> Self

Returns the “default value” for a type.

impl QueryBus for InMemoryQueryBus

fn dispatch<'life0, 'life1, 'async_trait, Q, R>( &'life0 self, ctx: &'life1 AppContext, q: Q, ) -> Pin<Box<dyn Future<Output = Result<R, AppError>> + Send + 'async_trait>>

where Q: Send + 'static + 'async_trait, R: Send + 'static + 'async_trait, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Dispatch a query and return its associated result.

fn dispatch_batch<'life0, 'life1, 'async_trait, Q, R>( &'life0 self, ctx: &'life1 AppContext, queries: Vec<Q>, ) -> Pin<Box<dyn Future<Output = Result<Vec<R>, AppError>> + Send + 'async_trait>>

where Q: Send + 'static + 'async_trait, R: Send + 'static + 'async_trait, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Dispatch a batch of queries in order, returning a parallel vector of results.