fn read_request(
        &mut self, 
        event_loop: &mut EventLoop<Self>) -> SocketEventResult {
        let mut consumed = 0;
        
        let len = try_arr!(self.stream.read(&mut *self.read_buffer, event_loop));
        
        //log_debug!(self.logger, "{} bytes read from the Arrow socket", len);
        
        while consumed < len {
            consumed += try_arr!(self.req_parser.add(
                &self.read_buffer[consumed..len]));
            if self.req_parser.is_complete() {
                let redirect = try_arr!(self.process_request(event_loop));
                if redirect.is_some() {
                    return Ok(redirect);
                }
            }
        }
        
        Ok(None)
    }
/// Read request data from the underlaying TLS socket.
Read request data from the underlaying TLS socket.
Read request data from the underlaying TLS socket .
fn read_request(
        &mut self, 
        event_loop: &mut EventLoop<Self>) -> SocketEventResult {
        let mut consumed = 0;
        let len = try_arr!(self.stream.read(&mut *self.read_buffer, event_loop));
        //log_debug!(self.logger, "{} bytes read from the Arrow socket", len);
        while consumed < len {
            consumed += try_arr!(self.req_parser.add(
                &self.read_buffer[consumed..len]));
            if self.req_parser.is_complete() {
                let redirect = try_arr!(self.process_request(event_loop));
                if redirect.is_some() {
                    return Ok(redirect);
                }
            }
        }
        Ok(None)
    }
fn read_request ( & mut self , event_loop : & mut EventLoop < Self > ) -> SocketEventResult { let mut consumed = 0 ; let len = try_arr ! ( self stream read ( mut self read_buffer event_loop ) ) ; //log_debug!(self.logger, "{} bytes read from the Arrow socket", len); while consumed < len { consumed += try_arr ! ( self req_parser add ( self read_buffer [ consumed len ] ) ) ; if self . req_parser . is_complete ( ) { let redirect = try_arr ! ( self process_request ( event_loop ) ) ; if redirect . is_some ( ) { return Ok ( redirect ) ; } } } Ok ( None ) }
Read request data from the underlaying TLS socket.
Read request data from the underlaying TLS socket .
&mut self
event_loop
&mut EventLoop<Self>
&mut self
event_loop
&mut EventLoop<Self>