Struct MessageQueue 

pub struct MessageQueue { /* private fields */ }

Implementations

impl MessageQueue

pub fn name(&self) -> Result<String>

pub fn set_name(&self, name: &str) -> Result<()>

pub fn is_closed(&self) -> Result<bool>

pub fn close(&self) -> Result<()>

pub fn set_blocking(&self, blocking: bool) -> Result<()>

pub fn blocking(&self) -> Result<bool>

pub fn set_max_size(&self, max_size: u32) -> Result<()>

pub fn max_size(&self) -> Result<u32>

pub fn size(&self) -> Result<u32>

pub fn is_full(&self) -> Result<bool>

pub fn has_message(&self) -> Result<bool>

pub fn get(&self, timeout: Option<Duration>) -> Result<Option<Datatype>>

pub fn try_get(&self) -> Result<Option<Datatype>>

pub fn front(&self) -> Result<Option<Datatype>>

pub fn try_get_all(&self) -> Result<Vec<Datatype>>

pub fn get_all( &self, timeout: Option<Duration>, ) -> Result<(Vec<Datatype>, bool)>

pub fn send(&self, msg: &Datatype) -> Result<()>

pub fn try_send(&self, msg: &Datatype) -> Result<bool>

pub fn send_timeout(&self, msg: &Datatype, timeout: Duration) -> Result<bool>

pub fn add_callback<F>(&self, callback: F) -> Result<QueueCallbackHandle>

where F: FnMut(&str, Datatype) + Send + 'static,

Trait Implementations

impl Clone for MessageQueue

fn clone(&self) -> MessageQueue

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.