ps-mpmc 0.1.0-1

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

use std::sync::mpsc;

use parking_lot::Mutex;

use crate::Receiver;

impl<T> Receiver<T> {
    #[must_use]
    pub fn from_inner_recv(receiver: mpsc::Receiver<T>) -> Self {
        Self::from_inner_mutex(Mutex::new(receiver))
    }
}