Struct ArchQueryReceiver

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

Query receiver 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> ArchQueryReceiver<U, V>

where U: SlxData, V: SlxData,

pub fn try_recv( &self, ) -> Result<(ArchData<U>, ArchOneshotSender<V>), TryRecvError>

Try to receive query of archived data without awaiting

• Output: the input archived data and the reply channel, or a reception diagnosis

pub async fn recv( &self, ) -> Result<(ArchData<U>, ArchOneshotSender<V>), RecvError>

Receive query of archived data

• Output: the input archived data and the reply channel, 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 ArchQueryReceiver<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.