Struct ArchQuerySender

pub struct ArchQuerySender<U, V>
where
    U: SlxData,
    V: SlxData,
{ /* private fields */ }

Query sender for archived data

• U : type of the query data; needs to implement SlxData
• V : type of the reply data; needs to implement SlxData

Implementations

impl<U, V> ArchQuerySender<U, V>

where U: SlxData, V: SlxData,

pub fn try_send( &self, (query, oneshot): (ArchData<U>, ArchOneshotSender<V>), ) -> Result<(), TrySendError<(ArchData<U>, ArchOneshotSender<V>)>>

Try to send query of archived data without awaiting

• (query,oneshot,) : (ArchData<U>, ArchOneshotSender<V>,) : archived input and reply channel
• Output: nothing or or a sending diagnosis

pub async fn send( &self, __arg1: (ArchData<U>, ArchOneshotSender<V>), ) -> Result<(), SendError<(ArchData<U>, ArchOneshotSender<V>)>>

Send query of archived data

• (query,oneshot,) : (ArchData<U>, ArchOneshotSender<V>,) : archived input and reply channel
• Output: nothing or an error

pub fn close(&self) -> bool

Close the channel: returns true if this call has closed the channel and it was not closed already

• Output: a boolean

pub fn is_closed(&self) -> bool

Is the channel closed?

• Output: a boolean

pub fn is_empty(&self) -> bool

Is the channel empty?

• Output: a boolean

pub fn is_full(&self) -> bool

Is the channel full?

• Output: a boolean

pub fn len(&self) -> usize

Number of messages in the channel

• Output: the number of messages

pub fn capacity(&self) -> Option<usize>

Capacity of the channel

• Output: the capacity if defined; otherwise the channel is unsized

pub fn receiver_count(&self) -> usize

Count the receivers

• Output: number of receivers

pub fn sender_count(&self) -> usize

Count the senders

• Output: number of senders

Trait Implementations

impl<U, V> Clone for ArchQuerySender<U, V>

where U: SlxData, V: SlxData,

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.