Struct ipc::message_queue::MessageQueue

pub struct MessageQueue<T> { /* fields omitted */ }

A POSIX message queue implementation

This is a one-way ipc protocol, the queuing process can read and immediately get the value that it just queued. If you want a two-way IPC method, use unix sockets.

Methods

impl<T> MessageQueue<T> where
    T: DeserializeOwned, 

fn new<S: AsRef<str>>(name: S) -> Result<MessageQueue<T>>

Trait Implementations

impl<T: Clone> Clone for MessageQueue<T>

fn clone(&self) -> MessageQueue<T>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for MessageQueue<T>

fn fmt(&self, __arg_0: &mut Formatter) -> Result

Formats the value using the given formatter.

impl<T> Sender for MessageQueue<T> where
    T: Serialize, 

type Item = T

fn send(&self, to_send: T) -> Result<()>

Synchronous send

fn async_send<'a>(
    &'a self,
    to_send: Self::Item
) -> Box<Future<Item = (), Error = Error> + 'a>

Asynchronous send

impl<T> Receiver for MessageQueue<T> where
    T: DeserializeOwned, 

type Item = T

fn recv(&self) -> Result<T>

Synchronous receive

fn async_recv<'a>(
    &'a self
) -> Box<Future<Item = Self::Item, Error = Error> + 'a>

Asynchronous receive

impl<T> Drop for MessageQueue<T>

fn drop(&mut self)

Executes the destructor for this type.