Trait QueryHandlerGat 

pub trait QueryHandlerGat<TQuery> {
    type Response;
    type HandleFuture<'a>: Future<Output = ApplicationResult<Self::Response>> + Send + 'a
       where Self: 'a;

    // Required method
    fn handle(&self, query: TQuery) -> Self::HandleFuture<'_>;
}

GAT-based query handler trait for zero-cost async

This trait uses Generic Associated Types instead of async_trait to avoid the boxing overhead of dynamic dispatch.

Required Associated Types

type Response

The response type for this query

type HandleFuture<'a>: Future<Output = ApplicationResult<Self::Response>> + Send + 'a where Self: 'a

Future type returned by handle method

Required Methods

fn handle(&self, query: TQuery) -> Self::HandleFuture<'_>

Handle the query and return a future

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl<R, S, F> QueryHandlerGat<GetStreamFramesQuery> for StreamQueryHandler<R, S, F>

where R: StreamRepositoryGat + Send + Sync, S: StreamStoreGat + Send + Sync, F: FrameStoreGat + Send + Sync,

type Response = FramesResponse

type HandleFuture<'a> = impl Future<Output = Result<<StreamQueryHandler<R, S, F> as QueryHandlerGat<GetStreamFramesQuery>>::Response, ApplicationError>> + Send + 'a where Self: 'a

impl<R, S, F> QueryHandlerGat<GetStreamQuery> for StreamQueryHandler<R, S, F>

where R: StreamRepositoryGat + Send + Sync, S: StreamStoreGat + Send + Sync, F: FrameStoreGat + Send + Sync,

type Response = StreamResponse

type HandleFuture<'a> = impl Future<Output = Result<<StreamQueryHandler<R, S, F> as QueryHandlerGat<GetStreamQuery>>::Response, ApplicationError>> + Send + 'a where Self: 'a

impl<R, S, F> QueryHandlerGat<GetStreamsForSessionQuery> for StreamQueryHandler<R, S, F>

where R: StreamRepositoryGat + Send + Sync, S: StreamStoreGat + Send + Sync, F: FrameStoreGat + Send + Sync,

type Response = StreamsResponse

type HandleFuture<'a> = impl Future<Output = Result<<StreamQueryHandler<R, S, F> as QueryHandlerGat<GetStreamsForSessionQuery>>::Response, ApplicationError>> + Send + 'a where Self: 'a

impl<R> QueryHandlerGat<GetActiveSessionsQuery> for SessionQueryHandler<R>

where R: StreamRepositoryGat + Send + Sync,

type Response = SessionsResponse

type HandleFuture<'a> = impl Future<Output = Result<<SessionQueryHandler<R> as QueryHandlerGat<GetActiveSessionsQuery>>::Response, ApplicationError>> + Send + 'a where Self: 'a

impl<R> QueryHandlerGat<GetSessionHealthQuery> for SessionQueryHandler<R>

where R: StreamRepositoryGat + Send + Sync,

type Response = HealthResponse

type HandleFuture<'a> = impl Future<Output = Result<<SessionQueryHandler<R> as QueryHandlerGat<GetSessionHealthQuery>>::Response, ApplicationError>> + Send + 'a where Self: 'a

impl<R> QueryHandlerGat<GetSessionQuery> for SessionQueryHandler<R>

where R: StreamRepositoryGat + Send + Sync,

type Response = SessionResponse

type HandleFuture<'a> = impl Future<Output = Result<<SessionQueryHandler<R> as QueryHandlerGat<GetSessionQuery>>::Response, ApplicationError>> + Send + 'a where Self: 'a

impl<R> QueryHandlerGat<GetSessionStatsQuery> for SessionQueryHandler<R>

where R: StreamRepositoryGat + Send + Sync,

type Response = SessionStatsResponse

type HandleFuture<'a> = impl Future<Output = Result<<SessionQueryHandler<R> as QueryHandlerGat<GetSessionStatsQuery>>::Response, ApplicationError>> + Send + 'a where Self: 'a

impl<R> QueryHandlerGat<GetSystemStatsQuery> for SystemQueryHandler<R>

where R: StreamRepositoryGat + Send + Sync,

type Response = SystemStatsResponse

type HandleFuture<'a> = impl Future<Output = Result<<SystemQueryHandler<R> as QueryHandlerGat<GetSystemStatsQuery>>::Response, ApplicationError>> + Send + 'a where Self: 'a

impl<R> QueryHandlerGat<SearchSessionsQuery> for SessionQueryHandler<R>

where R: StreamRepositoryGat + Send + Sync,

type Response = SessionsResponse

type HandleFuture<'a> = impl Future<Output = Result<<SessionQueryHandler<R> as QueryHandlerGat<SearchSessionsQuery>>::Response, ApplicationError>> + Send + 'a where Self: 'a