Struct LifecycleContext 

pub struct LifecycleContext<'a, A, R, P>
where
    A: AggregateRoot,
    R: Repository<Aggregate = A>,
    P: DomainEventPublisher<Event = <A as AggregateRoot>::Event>,
{ /* private fields */ }

English:
Coordinates one synchronous aggregate save and event dispatch sequence.

日本語:
同期の集約保存とイベント配信を一連で調整します。

Implementations

impl<'a, A, R, P> LifecycleContext<'a, A, R, P>

where A: AggregateRoot, R: Repository<Aggregate = A>, P: DomainEventPublisher<Event = <A as AggregateRoot>::Event>,

pub fn new( aggregate: &'a mut A, repository: &'a mut R, publisher: &'a mut P, ) -> LifecycleContext<'a, A, R, P>

English:
Creates a lifecycle context borrowing the aggregate, repository, and publisher mutably.

日本語:
集約、リポジトリ、パブリッシャーを可変借用するライフサイクルコンテキストを作成します。

Examples found in repository

examples/cqrs.rs (line 97)

    fn handle<F>(&mut self, id: &u64, amount: u32, callback: F) -> Result<(), Error>
    where
        F: for<'a> LifecycleCallback<'a, Order, Store, Publisher, Output = (), Error = Error>,
    {
        let mut order = self.store.find_by_id(id).unwrap().ok_or(Error::NotFound)?;
        if !Positive.is_satisfied_by(&amount).unwrap() {
            return Err(Error::Rejected);
        }
        let total = order.total.checked_add(amount).ok_or(Error::Rejected)?;
        Limit.check(&total)?;
        order.total = total;
        order.record_event(Placed(order.id));
        let mut context = LifecycleContext::new(&mut order, &mut self.store, &mut self.publisher);
        callback.call(&mut context)?;
        context.complete()?;
        Ok(())
    }

pub fn save( &mut self, ) -> Result<(), LifecycleOperationError<<R as Repository>::Error>>

English:
Attempts repository persistence once; adapter errors are returned and the attempt cannot be retried.

日本語:
リポジトリへの保存を一度試行します。アダプターエラーを返し、再試行はできません。

Examples found in repository

examples/cqrs.rs (line 116)

    fn call<'callback>(
        self,
        context: &'callback mut LifecycleContext<'storage, Order, Store, Publisher>,
    ) -> Result<(), Error>
    where
        'storage: 'callback,
    {
        context.save()?;
        context.dispatch()?;
        Ok(())
    }

pub fn dispatch( &mut self, ) -> Result<(), LifecycleOperationError<<P as DomainEventPublisher>::Error>>

English:
Attempts event dispatch once; adapter errors are returned and the attempt cannot be retried.

日本語:
イベント配信を一度試行します。アダプターエラーを返し、再試行はできません。

Examples found in repository

examples/cqrs.rs (line 117)

    fn call<'callback>(
        self,
        context: &'callback mut LifecycleContext<'storage, Order, Store, Publisher>,
    ) -> Result<(), Error>
    where
        'storage: 'callback,
    {
        context.save()?;
        context.dispatch()?;
        Ok(())
    }

pub fn complete(self) -> Result<(), LifecycleCompletionError>

English:
Consumes the context and succeeds only when both save and dispatch succeeded.

日本語:
コンテキストを消費し、保存と配信の両方が成功した場合にのみ成功します。

Examples found in repository

examples/cqrs.rs (line 99)

    fn handle<F>(&mut self, id: &u64, amount: u32, callback: F) -> Result<(), Error>
    where
        F: for<'a> LifecycleCallback<'a, Order, Store, Publisher, Output = (), Error = Error>,
    {
        let mut order = self.store.find_by_id(id).unwrap().ok_or(Error::NotFound)?;
        if !Positive.is_satisfied_by(&amount).unwrap() {
            return Err(Error::Rejected);
        }
        let total = order.total.checked_add(amount).ok_or(Error::Rejected)?;
        Limit.check(&total)?;
        order.total = total;
        order.record_event(Placed(order.id));
        let mut context = LifecycleContext::new(&mut order, &mut self.store, &mut self.publisher);
        callback.call(&mut context)?;
        context.complete()?;
        Ok(())
    }