Function magnetic::mpsc::mpsc_queue

pub fn mpsc_queue<T, B: Buffer<T>>(
    buf: B
) -> (MPSCProducer<T, B>, MPSCConsumer<T, B>)

Creates a new MPSC queue

Examples

use magnetic::mpsc::mpsc_queue;
use magnetic::buffer::dynamic::DynamicBuffer;
use magnetic::{Producer, Consumer};

let (p, c) = mpsc_queue(DynamicBuffer::new(32).unwrap());

p.push(1).unwrap();
assert_eq!(c.pop(), Ok(1));