Struct ProjectorHandler 

pub struct ProjectorHandler { /* private fields */ }

gRPC projector service implementation.

Wraps a handle function to process events and produce projections.

Implementations

impl ProjectorHandler

pub fn new(name: impl Into<String>) -> Self

Create a new projector handler.

pub fn with_handle(self, handle_fn: ProjectorHandleFn) -> Self

Set the handle function (function pointer).

pub fn with_handle_fn<H>(self, handle_fn: H) -> Self

where H: Fn(&EventBook) -> Result<Projection, Status> + Send + Sync + 'static,

Set the handle function (closure).

pub fn name(&self) -> &str

Get the projector name.

Trait Implementations

impl ProjectorService for ProjectorHandler

fn handle<'life0, 'async_trait>( &'life0 self, request: Request<EventBook>, ) -> Pin<Box<dyn Future<Output = Result<Response<Projection>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Async projection - projector should persist and return

fn handle_speculative<'life0, 'async_trait>( &'life0 self, request: Request<EventBook>, ) -> Pin<Box<dyn Future<Output = Result<Response<Projection>, Status>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Speculative processing - projector must avoid external side effects