stakker 0.2.15

A lightweight low-level single-threaded actor runtime
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

use crate::rc::minrc::MinRc;

pub(crate) struct FwdRc<M>(MinRc<dyn Fn(M)>);

impl<M> FwdRc<M> {
    #[inline]
    pub fn new(val: impl Fn(M) + 'static) -> Self {
        // Original code: Self(MinRc::new(val))

        // TODO: This is a CoerceUnsized workaround
        Self(MinRc::<dyn Fn(M)>::new_with(|| {
            Box::new(super::minrc::MinRcBox {
                count: std::cell::Cell::new(1),
                inner: val, // <= coerce appears to occur here
            })
        }))
    }

    #[inline]
    pub fn inner(&self) -> &dyn Fn(M) {
        self.0.inner()
    }
}

impl<M> Clone for FwdRc<M> {
    #[inline]
    fn clone(&self) -> Self {
        Self(self.0.clone())
    }
}