Struct eventually_util::optional::AsAggregate

source · [−]

pub struct AsAggregate<A>(_);

Expand description

Newtype pattern to ensure compatibility between optional::Aggregate trait and the core Aggregate trait.

Usage

Use From<Aggregate> trait implementation:

use eventually_util::optional::AsAggregate;

let aggregate = AsAggregate::from(MyOptionalAggregate);

Use the Aggregate::as_aggregate method:

let aggregate = MyOptionalAggregate.as_aggregate();

Trait Implementations

source

impl<A> Aggregate for AsAggregate<A> where
 A: Aggregate,
 A: Send + Sync,
 A::Id: Send + Sync,
 A::Command: Send + Sync,
 A::State: Send + Sync,

type Id = A::Id

Aggregate identifier: this should represent an unique identifier to refer to a unique Aggregate instance. Read more

type State = Option<A::State>

State of the Aggregate: this should represent the Domain Entity data structure.

type Event = A::Event

Represents a specific, domain-related change to the Aggregate State. Read more

type Command = A::Command

Commands are all the possible operations available on an Aggregate. Use Commands to model business use-cases or State mutations. Read more

type Error = A::Error

Possible failures while applying Events or handling Commands. Read more

source

fn apply(
state: Self::State,
event: Self::Event
) -> Result<Self::State, Self::Error>

Applies an Event to the current Aggregate State. Read more

source

fn handle<'a, 's: 'a>(
 &'a self,
 id: &'s Self::Id,
 state: &'s Self::State,
 command: Self::Command
) -> BoxFuture<'a, Result<Option<Vec<Self::Event>>, Self::Error>> where
 Self: Sized,

Handles the requested Command and returns a list of Events to apply the State mutation based on the current representation of the State. Read more

source

impl<A: Clone> Clone for AsAggregate<A>

source

fn clone(&self) -> AsAggregate<A>

Returns a copy of the value. Read more

1.0.0 · source

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source. Read more

source

impl<A> From<A> for AsAggregate<A>

source

fn from(value: A) -> Self

Performs the conversion.

Auto Trait Implementations

impl<A> RefUnwindSafe for AsAggregate<A> where
A: RefUnwindSafe,

impl<A> Send for AsAggregate<A> where
A: Send,

impl<A> Sync for AsAggregate<A> where
A: Sync,

impl<A> Unpin for AsAggregate<A> where
A: Unpin,

impl<A> UnwindSafe for AsAggregate<A> where
A: UnwindSafe,

Blanket Implementations

source

impl<T> AggregateExt for T where
T: Aggregate,

source

fn fold(state: Self::State, events: I) -> Result<Self::State, Self::Error> where
I: Iterator<Item = Self::Event>,

Applies a list of Events from an Iterator to the current Aggregate State. Read more

source

impl<T> Any for T where
T: 'static + ?Sized,

source

pub fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

source

impl<T> Borrow<T> for T where
T: ?Sized,

const: unstable · source

pub fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

source

impl<T> BorrowMut<T> for T where
T: ?Sized,

const: unstable · source

pub fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

source

impl<T> From<!> for T

const: unstable · source

pub fn from(t: !) -> T

Performs the conversion.

source

impl<T> From<T> for T

const: unstable · source

pub fn from(t: T) -> T

Performs the conversion.

source

impl<T, U> Into for T where
U: From<T>,

const: unstable · source

pub fn into(self) -> U

Performs the conversion.

source

impl<T> ToOwned for T where
T: Clone,

type Owned = T

The resulting type after obtaining ownership.

source

pub fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more

source

pub fn clone_into(&self, target: &mut T)

🔬 This is a nightly-only experimental API. (toowned_clone_into)

Uses borrowed data to replace owned data, usually by cloning. Read more

source

impl<T, U> TryFrom for T where
U: Into<T>,

type Error = Infallible

The type returned in the event of a conversion error.

const: unstable · source

pub fn try_from(value: U) -> Result<T, <T as TryFrom>::Error>

Performs the conversion.

source

impl<T, U> TryInto for T where
U: TryFrom<T>,

type Error = >::Error

The type returned in the event of a conversion error.

const: unstable · source

pub fn try_into(self) -> Result<U, >::Error>

Performs the conversion.

Struct eventually_util::optional::AsAggregate

Usage

Trait Implementations

impl<A> Aggregate for AsAggregate<A> where A: Aggregate, A: Send + Sync, A::Id: Send + Sync, A::Command: Send + Sync, A::State: Send + Sync,

type Id = A::Id

type State = Option<A::State>

type Event = A::Event

type Command = A::Command

type Error = A::Error

fn apply( state: Self::State, event: Self::Event) -> Result<Self::State, Self::Error>

fn handle<'a, 's: 'a>( &'a self, id: &'s Self::Id, state: &'s Self::State, command: Self::Command) -> BoxFuture<'a, Result<Option<Vec<Self::Event>>, Self::Error>> where Self: Sized,

impl<A: Clone> Clone for AsAggregate<A>

fn clone(&self) -> AsAggregate<A>

fn clone_from(&mut self, source: &Self)

impl<A> From<A> for AsAggregate<A>

fn from(value: A) -> Self

Auto Trait Implementations

impl<A> RefUnwindSafe for AsAggregate<A> where A: RefUnwindSafe,

impl<A> Send for AsAggregate<A> where A: Send,

impl<A> Sync for AsAggregate<A> where A: Sync,

impl<A> Unpin for AsAggregate<A> where A: Unpin,

impl<A> UnwindSafe for AsAggregate<A> where A: UnwindSafe,

Blanket Implementations

impl<T> AggregateExt for T where T: Aggregate,

fn fold<I>(state: Self::State, events: I) -> Result<Self::State, Self::Error> where I: Iterator<Item = Self::Event>,

impl<T> Any for T where T: 'static + ?Sized,

pub fn type_id(&self) -> TypeId

impl<T> Borrow<T> for T where T: ?Sized,

pub fn borrow(&self) -> &T

impl<T> BorrowMut<T> for T where T: ?Sized,

pub fn borrow_mut(&mut self) -> &mut T

impl<T> From<!> for T

pub fn from(t: !) -> T

impl<T> From<T> for T

pub fn from(t: T) -> T

impl<T, U> Into<U> for T where U: From<T>,

pub fn into(self) -> U

impl<T> ToOwned for T where T: Clone,

type Owned = T

pub fn to_owned(&self) -> T

pub fn clone_into(&self, target: &mut T)

impl<T, U> TryFrom<U> for T where U: Into<T>,

type Error = Infallible

pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for T where U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<A> Aggregate for AsAggregate<A> where
A: Aggregate,
A: Send + Sync,
A::Id: Send + Sync,
A::Command: Send + Sync,
A::State: Send + Sync,

fn apply(
state: Self::State,
event: Self::Event
) -> Result<Self::State, Self::Error>

fn handle<'a, 's: 'a>(
&'a self,
id: &'s Self::Id,
state: &'s Self::State,
command: Self::Command
) -> BoxFuture<'a, Result<Option<Vec<Self::Event>>, Self::Error>> where
Self: Sized,

impl<A> RefUnwindSafe for AsAggregate<A> where
A: RefUnwindSafe,

impl<A> Send for AsAggregate<A> where
A: Send,

impl<A> Sync for AsAggregate<A> where
A: Sync,

impl<A> Unpin for AsAggregate<A> where
A: Unpin,

impl<A> UnwindSafe for AsAggregate<A> where
A: UnwindSafe,

impl<T> AggregateExt for T where
T: Aggregate,

fn fold<I>(state: Self::State, events: I) -> Result<Self::State, Self::Error> where
I: Iterator<Item = Self::Event>,

impl<T> Any for T where
T: 'static + ?Sized,

impl<T> Borrow<T> for T where
T: ?Sized,

impl<T> BorrowMut<T> for T where
T: ?Sized,

impl<T, U> Into<U> for T where
U: From<T>,

impl<T> ToOwned for T where
T: Clone,

impl<T, U> TryFrom<U> for T where
U: Into<T>,

impl<T, U> TryInto<U> for T where
U: TryFrom<T>,