Struct BudgetedBody 

pub struct BudgetedBody {
    pub budget_exceeded: bool,
    pub total_bytes: u64,
    /* private fields */
}

Wraps an HttpBody and accumulates up to budget bytes while passing through all data. Tracks whether the budget was exceeded.

Fields

budget_exceeded: bool

Set to true when accumulated bytes exceed the budget.

total_bytes: u64

Total bytes passed through.

Implementations

impl BudgetedBody

pub fn new(inner: HttpBody, budget: usize) -> Self

pub fn accumulated_data(&self) -> Bytes

Returns a copy of the accumulated body data (up to budget).

Trait Implementations

impl Body for BudgetedBody

type Data = Bytes

Values yielded by the Body.

type Error = Box<dyn Error + Send + Sync>

The error type this Body might generate.

fn poll_frame( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Option<Result<Frame<Self::Data>, Self::Error>>>

Attempt to pull out the next data buffer of this stream.

fn is_end_stream(&self) -> bool

Returns true when the end of stream has been reached.

fn size_hint(&self) -> SizeHint

Returns the bounds on the remaining length of the stream.