pub fn add_stream_with<Q, FQ: FnMut(&T) -> Q>(&self, op: FQ) -> FutInnerUniRecv<RW, Q, FQ, T> {
        let rx = self.reader.add_stream();
        FutInnerUniRecv {
            reader: rx,
            wait: self.wait.clone(),
            prod_wait: self.prod_wait.clone(),
            op,
        }
    }
/// Adds another stream to the queue with a FutInnerUniRecv using the passed function
Adds another stream to the queue with a FutInnerUniRecv using the passed function
Adds another stream to the queue with a FutInnerUniRecv using the passed function
pub fn add_stream_with<Q, FQ: FnMut(&T) -> Q>(&self, op: FQ) -> FutInnerUniRecv<RW, Q, FQ, T> {
        let rx = self.reader.add_stream();
        FutInnerUniRecv {
            reader: rx,
            wait: self.wait.clone(),
            prod_wait: self.prod_wait.clone(),
            op,
        }
    }
pub fn add_stream_with < Q , FQ : FnMut ( & T ) -> Q > ( & self , op : FQ ) -> FutInnerUniRecv < RW , Q , FQ , T > { let rx = self . reader . add_stream ( ) ; FutInnerUniRecv { reader : rx , wait : self . wait . clone ( ) , prod_wait : self . prod_wait . clone ( ) , op , } }
Adds another stream to the queue with a FutInnerUniRecv using the passed function
Adds another stream to the queue with a FutInnerUniRecv using the passed function
&self
op
FQ
&self
op
FQ