Function magnetic::spsc::spsc_queue

pub fn spsc_queue<T, B: Buffer<T>>(
    buf: B
) -> (SPSCProducer<T, B>, SPSCConsumer<T, B>)

Creates a new SPSC queue

Examples

use magnetic::spsc::spsc_queue;
use magnetic::buffer::dynamic::DynamicBuffer;
use magnetic::{Producer, Consumer};

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

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