Trait akka_projection_rs::PendingHandler

pub trait PendingHandler {
    type Envelope: Send;

    const MAX_PENDING: usize;

    // Required method
    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;
}

Handle event envelopes in any way that an application requires.

Required Associated Types

type Envelope: Send

The envelope processed by the handler.

Required Associated Constants

const MAX_PENDING: usize

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

Required Methods

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.

Implementors

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

type Envelope = E

const MAX_PENDING: usize = 0usize