bottle 0.1.0

Actor model framework for Rust.
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

use crate::Remote;
use crate::thread::LOCAL_THREAD;

pub trait AsReceiver {
    fn as_receiver(&self) -> std::result::Result<Remote<Self>, NotReceiver>;
}

#[derive(Debug)]
pub struct NotReceiver;

impl<T> AsReceiver for T {
    fn as_receiver(&self) -> std::result::Result<Remote<T>, NotReceiver> {
        unsafe {
            if let Some(ref weak_thread) = LOCAL_THREAD {
                match weak_thread.clone().upgrade() {
                    Some(thread) => {
                        match thread.current_receiver(self) {
                            Some(remote) => Ok(remote),
                            None => Err(NotReceiver)
                        }
                    },
                    None => Err(NotReceiver)
                }
            } else {
                Err(NotReceiver)
            }
        }
    }
}