nitinol-process 0.1.0

Pseudo-actor type process library for Nitinol using green thread of tokio
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31

use std::fmt::Debug;

use async_trait::async_trait;
use nitinol_core::command::Command;
use crate::errors::ChannelDropped;
use crate::{Context, EventApplicator, Process, ProcessApplier, CommandHandler};

pub struct NonBlockingEntrustHandler<C: Command> {
    pub(crate) command: C,
}

#[async_trait]
impl<C: Command, T: Process> ProcessApplier<T> for NonBlockingEntrustHandler<C> 
where
    T: CommandHandler<C>,
    T::Rejection: Debug,
    T: EventApplicator<<T as CommandHandler<C>>::Event>,
{
    async fn apply(self: Box<Self>, entity: &mut T, ctx: &mut Context) -> Result<(), ChannelDropped> {
        match entity.handle(self.command, ctx).await {
            Ok(event) => {
                entity.apply(event, ctx).await;
                ctx.sequence += 1;
            }
            Err(rejection) => {
                tracing::error!("An error occurred: {:?}", rejection);
            }
        }
        Ok(())
    }
}