Relabuf - smart buffer with release valve
- consumes items from external async source
- buffers internally up to
hard_cap - when
hard_capis reached no longer consumes from external async source causing it to backoff and slow down - capable of releasing content ONLY under certain conditions
- a configurable time threshold is reached and buffer is not empty
- a configurable number of items were added
- each consumption should be either confirmed or returned to buffer
- returns usually happen due to error - so it's possible to configure a backoff
- backoff essentially overrides time release valve
Install
[dependencies]
relabuf = "~0.6.0"