kernel 1.1.0

Abstract Reactive Streams
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
40
41
42
43
44
45
46

use queues::publisher::Publisher;
use queues::publisher::Subscriber;
use core::cell::UnsafeCell;
use intercore::message::Message;

pub fn send<'a>(bus: &'a Channel, m: Message) {
    if let Some(v) = bus.publisher.next() {
        *v = m;
        bus.publisher.commit();
    };
}

pub enum TypeId {
    Byte,
    Int,
    Float,
}

pub struct Memory {
    publishers: UnsafeCell<Vec<Publisher<Message>>>,
    subscribers: UnsafeCell<Vec<Subscriber<Message>>>,
}

pub struct Channel {
    pub id: usize,
    pub publisher: Publisher<Message>,
    pub subscribers: Vec<Subscriber<Message>>,
}

impl Memory {
    pub fn new() -> Self {
        Memory {
            publishers: UnsafeCell::new(vec![]),
            subscribers: UnsafeCell::new(vec![]),
        }
    }
    #[inline]
    pub fn publishers(&self) -> &mut Vec<Publisher<Message>> {
        unsafe { &mut *self.publishers.get() }
    }

    #[inline]
    pub fn subscribers(&self) -> &mut Vec<Subscriber<Message>> {
        unsafe { &mut *self.subscribers.get() }
    }
}