Struct IpcStream

pub struct IpcStream { /* private fields */ }

Communication stream

Implementations

impl IpcStream

pub fn connect(logname: &str, socket_name: &str) -> Result<Self, IpcClientError>

Connects to the socket and return the stream

pub fn check_connection(socket_name: &str) -> Result<(), IpcClientError>

Check socket connection

pub fn alive(&mut self) -> Result<(), IpcClientError>

Check stream

pub fn send_message(&mut self, message: &Message) -> Result<(), IpcClientError>

Send Message.

pub fn receive_message(&mut self) -> Result<Message, IpcClientError>

Receive Message.

pub fn send_query( &mut self, request: &Message, ) -> Result<Message, IpcClientError>

Send a message and immediately read response message, blocking until a response is received.