core_bluetooth 0.1.0

Safe API wrapper for Core Bluetooth framework
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
47
48

#[cfg(not(feature = "async_std_unstable"))]
mod imp {
    use std::sync::mpsc;

    pub struct Sender<T>(mpsc::SyncSender<T>);

    impl<T> Sender<T> {
        #[must_use]
        pub fn send_blocking(&self, item: T) -> bool {
            self.0.send(item).is_ok()
        }
    }

    /// Receiving end of channel.
    pub type Receiver<T> = mpsc::Receiver<T>;

    pub fn channel<T>() -> (Sender<T>, Receiver<T>) {
        let (s, r) = mpsc::sync_channel(0);
        (Sender(s), r)
    }
}

#[cfg(feature = "async_std_unstable")]
mod imp {
    use async_std::sync;

    pub struct Sender<T>(sync::Sender<T>);

    impl<T> Sender<T> {
        #[must_use]
        pub fn send_blocking(&self, item: T) -> bool {
            async_std::task::block_on(async {
                self.0.send(item).await;
                true
            })
        }
    }

    /// Receiving end of channel.
    pub type Receiver<T> = sync::Receiver<T>;

    pub fn channel<T>() -> (Sender<T>, Receiver<T>) {
        let (s, r) = sync::channel(1);
        (Sender(s), r)
    }
}

pub use imp::*;