Struct BatchDemand 

pub struct BatchDemand {
    pub max_rows: usize,
    pub max_bytes: usize,
}

Maximum work a consumer is prepared to accept from one pull.

Fields

max_rows: usize

Maximum logical rows accepted in the next batch.

max_bytes: usize

Maximum retained bytes accepted in the next batch.

Implementations

impl BatchDemand

pub const fn new(max_rows: usize, max_bytes: usize) -> Self

Creates an explicit demand. Zero in either dimension means no work can currently be accepted and producers should report backpressure.

pub const fn can_accept_work(self) -> bool

Reports whether the consumer currently has capacity for work.

pub fn accepts<B: Batch>(self, batch: &B) -> bool

Reports whether a batch satisfies this demand.

Trait Implementations

impl Clone for BatchDemand

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Copy for BatchDemand

impl Debug for BatchDemand

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Eq for BatchDemand

impl PartialEq for BatchDemand

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for BatchDemand