pub fn into_single<R, F: FnMut(&T) -> R>(self, op: F) -> IntoSingleResult<RW, R, F, T> {
        let new_mreader;
        let new_pwait = self.prod_wait.clone();
        let new_wait = self.wait.clone();
        {
            new_mreader = self.reader.clone();
            drop(self);
        }
        if new_mreader.is_single() {
            Ok(FutInnerUniRecv {
                reader: new_mreader,
                wait: new_wait,
                prod_wait: new_pwait,
                op,
            })
        } else {
            Err((
                op,
                FutInnerRecv {
                    reader: new_mreader,
                    wait: new_wait,
                    prod_wait: new_pwait,
                },
            ))
        }
    }
/// Attempts to transform this receiver into a FutInnerUniRecv
/// calling the passed function on the input data.
Attempts to transform this receiver into a FutInnerUniRecv
calling the passed function on the input data.
Attempts to transform this receiver into a FutInnerUniRecv calling the passed function on the input data .
pub fn into_single<R, F: FnMut(&T) -> R>(self, op: F) -> IntoSingleResult<RW, R, F, T> {
        let new_mreader;
        let new_pwait = self.prod_wait.clone();
        let new_wait = self.wait.clone();
        {
            new_mreader = self.reader.clone();
            drop(self);
        }
        if new_mreader.is_single() {
            Ok(FutInnerUniRecv {
                reader: new_mreader,
                wait: new_wait,
                prod_wait: new_pwait,
                op,
            })
        } else {
            Err((
                op,
                FutInnerRecv {
                    reader: new_mreader,
                    wait: new_wait,
                    prod_wait: new_pwait,
                },
            ))
        }
    }
pub fn into_single < R , F : FnMut ( & T ) -> R > ( self , op : F ) -> IntoSingleResult < RW , R , F , T > { let new_mreader ; let new_pwait = self . prod_wait . clone ( ) ; let new_wait = self . wait . clone ( ) ; { new_mreader = self . reader . clone ( ) ; drop ( self ) ; } if new_mreader . is_single ( ) { Ok ( FutInnerUniRecv { reader : new_mreader , wait : new_wait , prod_wait : new_pwait , op , } ) } else { Err ( ( op , FutInnerRecv { reader : new_mreader , wait : new_wait , prod_wait : new_pwait , } , ) ) } }
Attempts to transform this receiver into a FutInnerUniRecv
calling the passed function on the input data.
Attempts to transform this receiver into a FutInnerUniRecv calling the passed function on the input data .
self
op
F
self
op
F