Struct akka_projection_rs_grpc::producer::GrpcEventProcessor

pub struct GrpcEventProcessor<E, Envelope, PF, T> { /* private fields */ }

Processes events transformed from some unknown event envelope (EI) to then pass on to a gRPC event producer.

Trait Implementations

impl<Envelope, E, PF, T> PendingHandler for GrpcEventProcessor<E, Envelope, PF, T>where Envelope: WithPersistenceId + WithSeqNr + WithSource + WithTags + WithTimestamp + Send, E: Send, PF: Fn(&Envelope) -> bool + Send, T: Fn(&Envelope) -> Option<E> + Send,

type Envelope = Envelope

The envelope processed by the handler.

const MAX_PENDING: usize = 10usize

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.