[][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.