oneshot 0.2.1

Oneshot spsc channel with (potentially) lock-free non-blocking send, and a receiver supporting both thread blocking receive operations as well as Future based async polling.
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

use oneshot::{Receiver, Sender};
use std::mem;

/// Just sanity check that both channel endpoints stay the size of a single pointer.
#[test]
fn channel_endpoints_single_pointer() {
    const PTR_SIZE: usize = mem::size_of::<*const ()>();

    assert_eq!(mem::size_of::<Sender<()>>(), PTR_SIZE);
    assert_eq!(mem::size_of::<Receiver<()>>(), PTR_SIZE);

    assert_eq!(mem::size_of::<Sender<u8>>(), PTR_SIZE);
    assert_eq!(mem::size_of::<Receiver<u8>>(), PTR_SIZE);

    assert_eq!(mem::size_of::<Sender<[u8; 1024]>>(), PTR_SIZE);
    assert_eq!(mem::size_of::<Receiver<[u8; 1024]>>(), PTR_SIZE);

    assert_eq!(mem::size_of::<Option<Sender<[u8; 1024]>>>(), PTR_SIZE);
    assert_eq!(mem::size_of::<Option<Receiver<[u8; 1024]>>>(), PTR_SIZE);
}

/// Check that the `SendError` stays small. Useful to automatically detect if it is refactored
/// to become large. We do not want the stack requirement for calling `Sender::send` to grow.
#[test]
fn error_sizes() {
    const PTR_SIZE: usize = mem::size_of::<usize>();

    assert_eq!(mem::size_of::<oneshot::SendError<()>>(), PTR_SIZE);
    assert_eq!(mem::size_of::<oneshot::SendError<u8>>(), PTR_SIZE);
    assert_eq!(mem::size_of::<oneshot::SendError<[u8; 1024]>>(), PTR_SIZE);

    // The type returned from `Sender::send` is also just pointer sized
    assert_eq!(
        mem::size_of::<Result<(), oneshot::SendError<[u8; 1024]>>>(),
        PTR_SIZE
    );
}