fn send_response(
        &mut self, 
        event_loop: &mut EventLoop<Self>) -> SocketEventResult {
        self.fill_output_buffer(event_loop);
        
        if self.output_buffer.is_empty() {
            self.stream.enable_socket_events(true, false, event_loop);
            self.write_tout.clear();
        } else {
            let len = {
                let data   = self.output_buffer.as_bytes();
                let len    = cmp::min(data.len(), self.write_buffer.len());
                let buffer = &mut self.write_buffer[..len];
                utils::memcpy(buffer, &data[..len]);
                try_arr!(self.stream.write(buffer, event_loop))
            };
            
            if len > 0 {
                //log_debug!(self.logger, "{} bytes written into the Arrow socket", len);
                self.write_tout.set(CONNECTION_TIMEOUT);
                self.output_buffer.drop(len);
            }
        }
        
        Ok(None)
    }
/// Send response data using the underlaying TLS socket.
Send response data using the underlaying TLS socket.
Send response data using the underlaying TLS socket .
fn send_response(
        &mut self, 
        event_loop: &mut EventLoop<Self>) -> SocketEventResult {
        self.fill_output_buffer(event_loop);
        if self.output_buffer.is_empty() {
            self.stream.enable_socket_events(true, false, event_loop);
            self.write_tout.clear();
        } else {
            let len = {
                let data   = self.output_buffer.as_bytes();
                let len    = cmp::min(data.len(), self.write_buffer.len());
                let buffer = &mut self.write_buffer[..len];
                utils::memcpy(buffer, &data[..len]);
                try_arr!(self.stream.write(buffer, event_loop))
            };
            if len > 0 {
                //log_debug!(self.logger, "{} bytes written into the Arrow socket", len);
                self.write_tout.set(CONNECTION_TIMEOUT);
                self.output_buffer.drop(len);
            }
        }
        Ok(None)
    }
fn send_response ( & mut self , event_loop : & mut EventLoop < Self > ) -> SocketEventResult { self . fill_output_buffer ( event_loop ) ; if self . output_buffer . is_empty ( ) { self . stream . enable_socket_events ( true , false , event_loop ) ; self . write_tout . clear ( ) ; } else { let len = { let data = self . output_buffer . as_bytes ( ) ; let len = cmp :: min ( data . len ( ) , self . write_buffer . len ( ) ) ; let buffer = & mut self . write_buffer [ .. len ] ; utils :: memcpy ( buffer , & data [ .. len ] ) ; try_arr ! ( self stream write ( buffer event_loop ) ) } ; if len > 0 { //log_debug!(self.logger, "{} bytes written into the Arrow socket", len); self . write_tout . set ( CONNECTION_TIMEOUT ) ; self . output_buffer . drop ( len ) ; } } Ok ( None ) }
Send response data using the underlaying TLS socket.
Send response data using the underlaying TLS socket .
&mut self
event_loop
&mut EventLoop<Self>
&mut self
event_loop
&mut EventLoop<Self>