Relabuf - smart buffer with release valve

• consumes items from external async source
• buffers internally up to hard_cap
• when hard_cap is 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"