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

//! A fast, small, full-featured async-aware oneshot channel
//!
//! Unique feature: wait for receiver to be waiting.
//!
//! Also supports the full range of things you'd expect.
#![no_std]
extern crate alloc;
use alloc::sync::Arc;

mod inner;
pub(crate) use inner::Inner;

mod sender;
pub use sender::Sender;

mod receiver;
pub use receiver::Receiver;

/// Create a new oneshot channel pair.
pub fn oneshot<T>() -> (Sender<T>, Receiver<T>) {
    let inner = Arc::new(Inner::new());
    let sender = Sender::new(inner.clone());
    let receiver = Receiver::new(inner);
    (sender, receiver)
}

/// An empty struct that signifies the channel is closed.
#[derive(Clone, Copy, Debug, Eq, PartialEq)]
pub struct Closed();

/// We couldn't receive a message.
#[derive(Debug)]
pub enum TryRecvError<T> {
    /// The Sender didn't send us a message yet.
    Empty(Receiver<T>),
    /// The Sender has dropped.
    Closed,
}