[−][src]Module yaque::queue
Queue implementation and utility functions.
Structs
Receiver | The receiver part of the queue. This part is asynchronous and therefore needs an executor that will the poll the futures to completion. |
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. |
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. |