/// Check connection timeout of the underlaying Arrow socket.
Check connection timeout of the underlaying Arrow socket.
Check connection timeout of the underlaying Arrow socket .
fn check_arrow_timeout(
        &mut self, 
        event_loop: &mut EventLoop<Self>) -> Result<()> {
        if !self.write_tout.check() || !self.ack_tout.check() {
            Err(ArrowError::connection_error("Arrow Service connection timeout"))
        } else {
            event_loop.timeout_ms(
                    TimerEvent::TimeoutCheck(0), 
                    TIMEOUT_CHECK_PERIOD)
                .unwrap();
            Ok(())
        }
    }
fn check_arrow_timeout ( & mut self , event_loop : & mut EventLoop < Self > ) -> Result < ( ) > { if ! self . write_tout . check ( ) || ! self . ack_tout . check ( ) { Err ( ArrowError :: connection_error ( " " ) ) } else { event_loop . timeout_ms ( TimerEvent :: TimeoutCheck ( 0 ) , TIMEOUT_CHECK_PERIOD ) . unwrap ( ) ; Ok ( ( ) ) } }
Check connection timeout of the underlaying Arrow socket.
Check connection timeout of the underlaying Arrow socket .
&mut self
event_loop
&mut EventLoop<Self>