waitfree-sync 0.4.0

A collection of wait-free data structures
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

use waitfree_sync::{spsc::SendError, *};

pub trait ReadPrimitive<T> {
    fn read(&mut self) -> Option<T>
    where
        T: Clone;
}
pub trait WritePrimitive<T, E> {
    fn write(&mut self, data: T) -> Result<(), E>;
}

impl<T> ReadPrimitive<T> for triple_buffer::Reader<T> {
    #[inline]
    fn read(&mut self) -> Option<T>
    where
        T: Clone,
    {
        self.try_read()
    }
}

impl<T> WritePrimitive<T, ()> for triple_buffer::Writer<T> {
    fn write(&mut self, data: T) -> Result<(), ()> {
        self.write(data);
        Ok(())
    }
}

impl<T> ReadPrimitive<T> for spsc::Receiver<T> {
    #[inline]
    fn read(&mut self) -> Option<T>
    where
        T: Clone,
    {
        self.try_recv().ok()
    }
}

impl<T> WritePrimitive<T, SendError<T>> for spsc::Sender<T> {
    fn write(&mut self, data: T) -> Result<(), SendError<T>> {
        self.try_send(data)
    }
}