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 const fn from_inner(inner: Arc<Mutex<mpsc::Receiver<T>>>) -> Self {
        Self { inner }
    }
}