Crate cuprate_async_buffer

Source
Expand description

Async Buffer

A bounded SPSC, FIFO, async buffer that supports arbitrary weights for values.

Weight is used to bound the channel, on creation you specify a max weight and for each value you specify a weight.

Structs§

BufferAppender
The appender/sink side of the buffer.
BufferSinkReady
A Future for waiting for capacity in the buffer.
BufferSinkSend
A Future for adding an item to the buffer.
BufferStream
The stream side of the buffer.

Enums§

BufferError

Functions§

new_buffer
Initializes a new buffer with the provided capacity.