Struct BodyGuard 

pub struct BodyGuard<B> { /* private fields */ }

A body wrapped with explicit lifecycle policy.

Implementations

impl<B> BodyGuard<B>

pub fn new(inner: B) -> Self

Create a new guarded body.

pub fn with_policy(inner: B, policy: BodyPolicy) -> Self

Create a new guarded body with an explicit policy.

pub fn max_bytes(self, bytes: u64) -> Self

Set the maximum accepted body size in bytes.

pub fn overflow(self, policy: OverflowPolicy) -> Self

Set overflow behavior.

pub fn drop_policy(self, policy: DropPolicy) -> Self

Set drop behavior.

pub fn drain_policy(self, policy: DrainPolicy) -> Self

Set drain behavior.

pub fn replay_policy(self, policy: ReplayPolicy) -> Self

Set replay behavior.

pub fn shutdown_policy(self, policy: ShutdownPolicy) -> Self

Set shutdown behavior.

pub fn state(&self) -> BodyState

Return the current lifecycle state.

pub fn policy(&self) -> &BodyPolicy

Return the configured policy.

pub fn bytes_seen(&self) -> u64

Return the number of bytes observed through this guard.

pub fn mark_pending(&mut self)

Mark the body as waiting for an underlying body or stream to become ready.

pub fn mark_reading(&mut self)

Mark the body as currently being read.

pub fn mark_draining(&mut self)

Mark the body as draining.

pub fn mark_completed(&mut self)

Mark the body as completed.

pub fn mark_aborted(&mut self)

Mark the body as aborted.

pub fn observe_bytes(&mut self, bytes: u64) -> BodyDecision

Record newly observed bytes and return the policy decision.

pub fn into_inner(self) -> B

Consume the guard and return the inner body.

Trait Implementations

impl<B: Debug> Debug for BodyGuard<B>

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

Formats the value using the given formatter.