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

use nitinol_core::identifier::ToEntityId;

use crate::errors::{AlreadyExist, InvalidCast};
use crate::registry::ProcessRegistry;
use crate::{lifecycle, Process, Receptor};

#[derive(Clone, Default)]
pub struct ProcessManager {
    registry: ProcessRegistry
}

impl ProcessManager {
    pub async fn spawn<T: Process>(&self, entity: T, start_seq: i64) -> Result<Receptor<T>, AlreadyExist> {
        lifecycle::run(entity.aggregate_id(), entity, start_seq, self.registry.clone()).await
    }

    pub async fn find<T: Process>(&self, id: impl ToEntityId) -> Result<Option<Receptor<T>>, InvalidCast> {
        self.registry.find::<T>(&id.to_entity_id()).await
    }
}