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
32
33
34
35
36
37
38
39

use std::fmt::Debug;
use super::ProcessApplier;
use crate::errors::ChannelDropped;
use crate::{Process, Context};
use async_trait::async_trait;
use nitinol_core::command::Command;
use nitinol_core::event::Event;
use tokio::sync::oneshot;

#[async_trait]
pub trait CommandHandler<C: Command>: 'static + Sync + Send {
    type Event: Event;
    type Rejection: Debug + 'static + Sync + Send;
    async fn handle(&self, command: C, ctx: &mut Context) -> Result<Self::Event, Self::Rejection>;
}

pub(crate) struct CommandReceptor<C: Command, T: Process>
where
    T: CommandHandler<C>,
{
    pub(crate) command: C,
    pub(crate) oneshot: oneshot::Sender<Result<T::Event, T::Rejection>>,
}

#[async_trait::async_trait]
impl<C: Command, T: Process> ProcessApplier<T> for CommandReceptor<C, T>
where
    T: CommandHandler<C>,
{
    async fn apply(
        self: Box<Self>,
        entity: &mut T,
        ctx: &mut Context,
    ) -> Result<(), ChannelDropped> {
        self.oneshot
            .send(entity.handle(self.command, ctx).await)
            .map_err(|_| ChannelDropped)
    }
}