fn arrow_socket_ready(
        &mut self, 
        event_loop: &mut EventLoop<Self>, 
        event_set: EventSet) -> SocketEventResult {
        let res = try_arr!(self.check_arrow_read_event(event_loop, event_set));
        if res.is_some() {
            return Ok(res);
        }
        
        let res = try_arr!(self.check_arrow_write_event(event_loop, event_set));
        if res.is_some() {
            return Ok(res);
        }
        
        if event_set.is_error() {
            let socket_err = self.stream.take_socket_error();
            Err(ArrowError::connection_error(socket_err.unwrap_err()))
        } else if event_set.is_hup() {
            Err(ArrowError::connection_error("connection to Arrow Service lost"))
        } else {
            Ok(None)
        }
    }
/// Process all notifications for the underlaying TLS socket.
Process all notifications for the underlaying TLS socket.
Process all notifications for the underlaying TLS socket .
fn arrow_socket_ready(
        &mut self, 
        event_loop: &mut EventLoop<Self>, 
        event_set: EventSet) -> SocketEventResult {
        let res = try_arr!(self.check_arrow_read_event(event_loop, event_set));
        if res.is_some() {
            return Ok(res);
        }
        let res = try_arr!(self.check_arrow_write_event(event_loop, event_set));
        if res.is_some() {
            return Ok(res);
        }
        if event_set.is_error() {
            let socket_err = self.stream.take_socket_error();
            Err(ArrowError::connection_error(socket_err.unwrap_err()))
        } else if event_set.is_hup() {
            Err(ArrowError::connection_error("connection to Arrow Service lost"))
        } else {
            Ok(None)
        }
    }
fn arrow_socket_ready ( & mut self , event_loop : & mut EventLoop < Self > , event_set : EventSet ) -> SocketEventResult { let res = try_arr ! ( self check_arrow_read_event ( event_loop event_set ) ) ; if res . is_some ( ) { return Ok ( res ) ; } let res = try_arr ! ( self check_arrow_write_event ( event_loop event_set ) ) ; if res . is_some ( ) { return Ok ( res ) ; } if event_set . is_error ( ) { let socket_err = self . stream . take_socket_error ( ) ; Err ( ArrowError :: connection_error ( socket_err . unwrap_err ( ) ) ) } else if event_set . is_hup ( ) { Err ( ArrowError :: connection_error ( " " ) ) } else { Ok ( None ) } }
Process all notifications for the underlaying TLS socket.
Process all notifications for the underlaying TLS socket .
&mut self
event_loop
&mut EventLoop<Self>
event_set
EventSet
&mut self
event_loop
&mut EventLoop<Self>
event_set
EventSet