ps-mpmc 0.1.0-1

multi-producer multi-consumer queue
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14

use std::sync::mpsc::channel;

use crate::{Receiver, MPMC};

impl<T> Default for MPMC<T> {
    fn default() -> Self {
        let (sender, receiver) = channel();

        Self {
            receiver: Receiver::from_inner_recv(receiver),
            sender,
        }
    }
}