Module yaque::queue

Queue implementation and utility functions.

Structs

• QueueIter
  An Iterator that iterates over the elements of the queue, until it hts the end for the first time. Use this structure instead of crate::Receiver if you just need to read the data stored in a queue.
• Receiver
  The receiver part of the queue. This part is asynchronous and therefore needs an executor that will the poll the futures to completion.
• ReceiverBuilder
  A builder for the receiver side of the queue. Use this if you want to have fine-grained control over the configuration of the queue. Most defaults should be ok of most applications.
• RecvGuard
  A guard that will only log changes on the queue state when dropped.
• Sender
  The sender part of the queue. This part is lock-free and therefore can be used outside an asynchronous context.
• SenderBuilder
  A builder for the sender side of the queue. Use this if you want to have fine-grained control over the configuration of the queue. Most defaults should be ok of most applications.

Functions

• channel
  Convenience function for opening the queue for both sending and receiving.
• clear
  Deletes a queue at the given path. This function will await the queue to become available for both sending and receiving.
• try_clear
  Tries to deletes a queue at the given path. This function will fail if the queue is in use either for sending or receiving.