cedar 0.1.1

Reactive, functional library for creating GUI applications
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


use std;
use std::sync::Arc;
use crossbeam::sync::MsQueue;

pub struct Stream<T>(Arc<MsQueue<T>>);

impl<T> Stream<T> {
    pub fn new() -> Self {
        Stream(Arc::new(MsQueue::new()))
    }
}

impl<T> Clone for Stream<T> {
    fn clone(&self) -> Self {
        Stream(self.0.clone())
    }
}

impl<T> std::ops::Deref for Stream<T> {
    type Target = Arc<MsQueue<T>>;

    fn deref(&self) -> &Self::Target {
        &self.0
    }
}