/// Parse a Control Protocol message from the underlaying Arrow Message 
/// parser.
Parse a Control Protocol message from the underlaying Arrow Message
parser.
Parse a Control Protocol message from the underlaying Arrow Message parser .
fn parse_control_message(&self) -> Result<(ControlMessageHeader, Vec<u8>)> {
        if let Some(body) = self.req_parser.body() {
            let mut parser = ControlMessageParser::new();
            try_arr!(parser.process(body));
            let header = parser.header();
            let body   = parser.body();
            if header.message_type() == ControlMessageType::UNKNOWN {
                Err(ArrowError::other("unknown Control Protocol message type"))
            } else {
                Ok((header.clone(), body.to_vec()))
            }
        } else {
            panic!("incomplete message");
        }
    }
fn parse_control_message ( & self ) -> Result < ( ControlMessageHeader , Vec < u8 > ) > { if let Some ( body ) = self . req_parser . body ( ) { let mut parser = ControlMessageParser :: new ( ) ; try_arr ! ( parser process ( body ) ) ; let header = parser . header ( ) ; let body = parser . body ( ) ; if header . message_type ( ) == ControlMessageType :: UNKNOWN { Err ( ArrowError :: other ( " " ) ) } else { Ok ( ( header . clone ( ) , body . to_vec ( ) ) ) } } else { panic ! ( " " ) ; } }
Parse a Control Protocol message from the underlaying Arrow Message
parser.
Parse a Control Protocol message from the underlaying Arrow Message parser .
&self