Struct UpcasterGrpcHandler 

pub struct UpcasterGrpcHandler { /* private fields */ }

gRPC upcaster service implementation.

Wraps a handle function to transform events to current versions.

Implementations

impl UpcasterGrpcHandler

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

Create a new upcaster handler.

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

Set the handle function (function pointer).

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

where H: Fn(&[EventPage]) -> Vec<EventPage> + Send + Sync + 'static,

Set the handle function (closure).

pub fn name(&self) -> &str

Get the upcaster name.

pub fn domain(&self) -> &str

Get the domain this upcaster handles.

Trait Implementations

impl UpcasterService for UpcasterGrpcHandler

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

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

Transform events to current version Returns events in same order, transformed where applicable