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§
- Buffer
Appender - The appender/sink side of the buffer.
- Buffer
Sink Ready - A
Futurefor waiting for capacity in the buffer. - Buffer
Sink Send - A
Futurefor adding an item to the buffer. - Buffer
Stream - The stream side of the buffer.
Enums§
Functions§
- new_
buffer - Initializes a new buffer with the provided capacity.