Struct Manual 

pub struct Manual<E: Event> { /* private fields */ }

Available on crate feature cqrs only.

Manual conflict resolver: delegates to a user-provided callback.

Implementations

impl<E: Event> Manual<E>

pub fn new<F, Fut>(f: F) -> Self

where F: Fn(Vec<E>, Vec<E>) -> Fut + Send + Sync + 'static, Fut: Future<Output = Vec<E>> + Send + 'static,

Create a manual resolver with the given callback.

Trait Implementations

impl<E: Event> ConflictResolver<E> for Manual<E>

fn resolve<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, local: &'life1 [E], remote: &'life2 [E], ) -> Pin<Box<dyn Future<Output = Vec<E>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Given conflicting local and remote events, produce a resolved set.