pub fn add_stream(&self) -> FutInnerRecv<RW, T> {
        let rx = self.reader.add_stream();
        FutInnerRecv {
            reader: rx,
            wait: self.wait.clone(),
            prod_wait: self.prod_wait.clone(),
        }
    }
/// Creates a new stream and returns a FutInnerRecv on that stream
Creates a new stream and returns a FutInnerRecv on that stream
Creates a new stream and returns a FutInnerRecv on that stream
pub fn add_stream(&self) -> FutInnerRecv<RW, T> {
        let rx = self.reader.add_stream();
        FutInnerRecv {
            reader: rx,
            wait: self.wait.clone(),
            prod_wait: self.prod_wait.clone(),
        }
    }
pub fn add_stream ( & self ) -> FutInnerRecv < RW , T > { let rx = self . reader . add_stream ( ) ; FutInnerRecv { reader : rx , wait : self . wait . clone ( ) , prod_wait : self . prod_wait . clone ( ) , } }
Creates a new stream and returns a FutInnerRecv on that stream
Creates a new stream and returns a FutInnerRecv on that stream
&self
&self