Struct ipc_queue::Sender

pub struct Sender<T: 'static, S> { /* fields omitted */ }

Implementations

impl<T: Transmittable, S: Synchronizer> Sender<T, S>

pub unsafe fn from_descriptor(d: FifoDescriptor<T>, synchronizer: S) -> Self

Create a Sender from a FifoDescriptor and Synchronizer.

Safety

The caller must ensure the following:

• The data and len fields in FifoDescriptor must adhere to all safety requirements described in std::slice::from_raw_parts_mut()

• The offsets field in FifoDescriptor must be non-null and point to a valid memory location holding an AtomicUsize.

• The synchronizer must somehow know how to correctly synchronize with the other end of the channel.

pub fn try_send(&self, val: Identified<T>) -> Result<(), TrySendError>

pub fn try_send_multiple(
    &self,
    values: &[Identified<T>]
) -> Result<usize, TrySendError>

Tries to send multiple values. Calling this function has the same semantics as calling try_send for each item in order until an error occurs, but it has the benefit of notifying the receiver at most once.

Returns the number of successfully sent items if any item was successfully sent, otherwise returns an error.

pub fn send(&self, val: Identified<T>) -> Result<(), SendError>

Trait Implementations

impl<T, S: Clone> Clone for Sender<T, S>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Send, S: Send> Send for Sender<T, S>

impl<T: Send, S: Sync> Sync for Sender<T, S>