Struct BoundedMailboxQueue 

pub struct BoundedMailboxQueue { /* private fields */ }

Trait Implementations

impl Clone for BoundedMailboxQueue

fn clone(&self) -> BoundedMailboxQueue

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BoundedMailboxQueue

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl QueueBase<MessageHandle> for BoundedMailboxQueue

fn len<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = QueueSize> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns the length of this queue.
このキューの長さを返します。

fn capacity<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = QueueSize> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns the capacity of this queue.
このキューの最大容量を返します。

fn is_empty<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns whether this queue is empty.
このキューが空かどうかを返します。

fn non_empty<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns whether this queue is non-empty.
このキューが空でないかどうかを返します。

fn is_full<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns whether the queue size has reached its capacity.
このキューのサイズが容量まで到達したかどうかを返します。

fn non_full<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns whether the queue size has not reached its capacity.
このキューのサイズが容量まで到達してないかどうかを返します。

impl QueueReader<MessageHandle> for BoundedMailboxQueue

fn poll<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<Option<MessageHandle>, QueueError<MessageHandle>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Retrieves and deletes the head of the queue. Returns None if the queue is empty.
キューの先頭を取得および削除します。キューが空の場合は None を返します。

fn clean_up<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

impl QueueWriter<MessageHandle> for BoundedMailboxQueue

fn offer<'life0, 'async_trait>( &'life0 mut self, element: MessageHandle, ) -> Pin<Box<dyn Future<Output = Result<(), QueueError<MessageHandle>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

The specified element will be inserted into this queue, if the queue can be executed immediately without violating the capacity limit.
容量制限に違反せずにすぐ実行できる場合は、指定された要素をこのキューに挿入します。

fn offer_all<'life0, 'async_trait>( &'life0 mut self, elements: Vec<E>, ) -> Pin<Box<dyn Future<Output = Result<(), QueueError<E>>> + Send + 'async_trait>>

where Self: Send + 'async_trait, 'life0: 'async_trait,

The specified elements will be inserted into this queue, if the queue can be executed immediately without violating the capacity limit.
容量制限に違反せずにすぐ実行できる場合は、指定された複数の要素をこのキューに挿入します。