Crate cuprate_async_buffer

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.