Struct akka_persistence_rs::effect::Reply

pub struct Reply<B, T> { /* private fields */ }

The return type of reply.

Trait Implementations

impl<B, T> Effect<B> for Reply<B, T>where B: EventSourcedBehavior + Send + Sync + 'static, T: Send,

fn process<'life0, 'life1, 'life2, 'life3, 'life4, 'life5, 'async_trait>( &'life0 mut self, _behavior: &'life1 B, _handler: &'life2 mut (dyn Handler<B::Event> + Send), _entities: &'life3 mut (dyn EntityOps<B> + Send + Sync), _entity_id: &'life4 EntityId, _last_seq_nr: &'life5 mut u64, prev_result: Result ) -> Pin<Box<dyn Future<Output = Result> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait, 'life5: 'async_trait,

Consume the effect asynchronously. This operation may be performed multiple times, but only the first time is expected to perform the effect.

impl<B, T> EffectExt<B> for Reply<B, T>where B: EventSourcedBehavior + Send + Sync + 'static, T: Send,

fn and<R>(self, r: R) -> And<B, Self, R>where Self: Sized, R: Effect<B>,

Perform the provided effect after this current one.

fn boxed(self) -> Box<dyn Effect<B>>where Self: Sized + 'static,

Box the effect for the purposes of returning it.