Struct BackpressureConsumer 

pub struct BackpressureConsumer { /* private fields */ }

A consumer that releases credits back to the pool as items are processed.

Implementations

impl BackpressureConsumer

pub fn new(pool: CreditPool) -> Self

Create a consumer that shares the given CreditPool.

pub fn consume(&mut self, credits: i64)

Mark credits worth of processing as complete, releasing those credits back to the pool so the producer can emit more items.

pub fn consumed_total(&self) -> u64

Total items consumed (i.e. times consume() was called) since creation.

pub fn pool(&self) -> &CreditPool

Shared reference to the underlying credit pool.