nitinol-process 0.1.1

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

use super::Receptor;
use crate::Process;
use std::any::{type_name, Any};
use std::sync::Arc;
use crate::errors::InvalidCast;

pub trait DynRef: 'static + Sync + Send {
    fn as_any(&self) -> &dyn Any;
}

pub(crate) struct AnyRef(Arc<dyn DynRef>);

impl AnyRef {
    pub fn downcast<T: Process>(&self) -> Result<Receptor<T>, InvalidCast> {
        self.0.as_any()
            .downcast_ref::<Receptor<T>>()
            .cloned()
            .ok_or(InvalidCast { to: type_name::<T>() })
    }
}

impl Clone for AnyRef {
    fn clone(&self) -> Self {
        Self(Arc::clone(&self.0))
    }
}

impl<T: Process> From<Receptor<T>> for AnyRef {
    fn from(value: Receptor<T>) -> Self {
        Self(Arc::new(value))
    }
}