/// Send a given Arrow Message.
Send a given Arrow Message.
Send a given Arrow Message .
fn send_message<B: ArrowMessageBody>(
        &mut self, 
        arrow_msg: &ArrowMessage<B>, 
        event_loop: &mut EventLoop<Self>) {
        if self.output_buffer.is_empty() {
            self.write_tout.set(CONNECTION_TIMEOUT);
        }
        arrow_msg.serialize(&mut self.output_buffer)
            .unwrap();
        self.stream.enable_socket_events(true, true, event_loop);
    }
fn send_message < B : ArrowMessageBody > ( & mut self , arrow_msg : & ArrowMessage < B > , event_loop : & mut EventLoop < Self > ) { if self . output_buffer . is_empty ( ) { self . write_tout . set ( CONNECTION_TIMEOUT ) ; } arrow_msg . serialize ( & mut self . output_buffer ) . unwrap ( ) ; self . stream . enable_socket_events ( true , true , event_loop ) ; }
Send a given Arrow Message.
Send a given Arrow Message .
&mut self
arrow_msg
&ArrowMessage<B>
event_loop
&mut EventLoop<Self>