Crate wb_async_utils

Re-exports

pub use rw::RwLock;

pub use mutex::Mutex;

Modules

mutex

rw

shared_consumer

Provides SharedConsumer, a way for creating multiple independent handles that coordinate termporary exclusive access to a shared underlying consumer.

shared_producer

Provides SharedProducer, a way for creating multiple independent handles that coordinate termporary exclusive access to a shared underlying producer.

shelf

This module provides an abstraction for two communicating endpoints: a synchronous Sender sends data to an async Receiver. When the Sender is instructed to send even though the Receiver has not yet accepted the previously sent item, that item is simply overwritten and lost forever. The Sender can further indicate that it will not send any more data in the future (this maps to the Producer implementation of the Receiver emitting a Final item).

spsc

This module provides a nonblocking single producer single consumer channel backed by an arbitrary Queue, with a UFOTOFU-based interface.

Structs

OnceCell

An optional value that can be set to a Some at most once, and which allows to .await that time.

TakeCell

An async cell akin to an Option, whose value can only be accessed via an async take method that non-blocks while the cell is empty.