Struct akka_projection_rs::UnusedPendingHandler

pub struct UnusedPendingHandler<E> {
    pub phantom: PhantomData<E>,
}

For the purposes of constructing unused handlers.

Fields

phantom: PhantomData<E>

Trait Implementations

impl<E> PendingHandler for UnusedPendingHandler<E>where E: Send,

type Envelope = E

The envelope processed by the handler.

const MAX_PENDING: usize = 0usize

The maximum number of envelopes that can be pending at any time.

fn process_pending<'life0, 'async_trait>( &'life0 mut self, _envelope: Self::Envelope ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Future<Output = Result<(), HandlerError>> + Send>>, HandlerError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Process an envelope with a pending result. A handler’s result is “pending” when envelopes can be passed through and the result of processing one is not immediately known. Meanwhile, more envelopes can be passed though.