ps-mpmc 0.1.0-1

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

use std::sync::{mpsc, Arc};

use parking_lot::Mutex;

use crate::Receiver;

impl<T> Receiver<T> {
    pub fn from_inner_mutex(mutex: Mutex<mpsc::Receiver<T>>) -> Self {
        Self::from_inner(Arc::new(mutex))
    }
}