Struct Body 

pub struct Body<P> { /* private fields */ }

A predicate that matches HTTP bodies against an Operation.

Works with both requests and responses through the CacheableSubject trait. Chain with other predicates using the builder pattern.

Type Parameters

• P - The inner predicate to chain with. Use Body::new to start a new predicate chain (uses Neutral internally), or use the BodyPredicate extension trait to chain onto an existing predicate.

Examples

use hitbox_http::predicates::body::{Body, Operation};

// Only cache responses smaller than 1MB
let predicate = Body::new(Operation::Limit { bytes: 1024 * 1024 });

Caveats

Body predicates consume bytes from the stream. The body is buffered during evaluation and returned in a BufferedBody state. Order body predicates last in a chain when possible.

Implementations

impl<S> Body<Neutral<S>>

pub fn new(operation: Operation) -> Self

Creates a predicate that matches body content against the operation.

Returns Cacheable when the body satisfies the operation, NonCacheable otherwise.

Chain onto existing predicates using BodyPredicate::body instead if you already have a predicate chain.

Trait Implementations

impl<P: Debug> Debug for Body<P>

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

Formats the value using the given formatter.

impl<P> Predicate for Body<P>

where P: Predicate + Send + Sync, P::Subject: CacheableSubject + Send, <P::Subject as CacheableSubject>::Body: Send + Unpin + 'static, <P::Subject as CacheableSubject>::Parts: Send, <<P::Subject as CacheableSubject>::Body as HttpBody>::Error: Send, <<P::Subject as CacheableSubject>::Body as HttpBody>::Data: Send,

type Subject = <P as Predicate>::Subject

The type being evaluated by this predicate.

fn check<'life0, 'async_trait>( &'life0 self, subject: Self::Subject, ) -> Pin<Box<dyn Future<Output = PredicateResult<Self::Subject>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Evaluate whether the subject should be cached.