Struct akka_persistence_rs::effect::And
source · pub struct And<E, L, R> { /* private fields */ }
Expand description
The return type of EffectExt::and.
Trait Implementations§
source§impl<B, L, R> Effect<B> for And<B, L, R>where
B: EventSourcedBehavior + Send + Sync + 'static,
B::State: Send,
L: Effect<B>,
R: Effect<B>,
impl<B, L, R> Effect<B> for And<B, L, R>where B: EventSourcedBehavior + Send + Sync + 'static, B::State: Send, L: Effect<B>, R: Effect<B>,
source§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,
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.
Auto Trait Implementations§
impl<E, L, R> RefUnwindSafe for And<E, L, R>where E: RefUnwindSafe, L: RefUnwindSafe, R: RefUnwindSafe,
impl<E, L, R> Send for And<E, L, R>where E: Send, L: Send, R: Send,
impl<E, L, R> Sync for And<E, L, R>where E: Sync, L: Sync, R: Sync,
impl<E, L, R> Unpin for And<E, L, R>where E: Unpin, L: Unpin, R: Unpin,
impl<E, L, R> UnwindSafe for And<E, L, R>where E: UnwindSafe, L: UnwindSafe, R: UnwindSafe,
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more