Module yaque::queue [−][src]
Expand description
Queue implementation and utility functions.
Structs
QueueIter | An |
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 sould 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. |