Struct HtmlRewriteBody 

pub struct HtmlRewriteBody<B, H> { /* private fields */ }

Available on crate features html and http only.

A response body that feeds the inner body’s bytes through an HtmlRewriter, emitting rewritten chunks as they become available.

Build it directly with new (rewriting) or passthrough (forward unchanged), or let HtmlRewriteLayer construct one per response. Attach on_end to recover the handler (and any state it accumulated) once the rewrite finishes.

Implementations

impl<B, H> HtmlRewriteBody<B, H>

where H: ElementContentHandler,

pub fn new( inner: B, selectors: &[Selector], handler: H, ) -> HtmlRewriteBody<B, H>

Wraps inner, rewriting elements matching selectors with handler (the selector index passed to the handler is the index into selectors).

impl<B, H> HtmlRewriteBody<B, H>

pub fn passthrough(inner: B) -> HtmlRewriteBody<B, H>

Wraps inner without rewriting — frames pass through unchanged (their data type normalized to Bytes).

Lets a layer keep one body type for responses it must not rewrite (e.g. a non-HTML content type).

pub fn on_end<F>(self, on_end: F) -> HtmlRewriteBody<B, H>

where F: FnOnce(H) + Send + Sync + 'static,

Installs a completion hook, handed the finalized handler by value after the rewrite ends — for reading state it accumulated.

Fires once after HtmlRewriter::end on clean termination (inner EOF or trailers); not on the error path, nor in passthrough mode (no handler). A later call replaces an earlier hook.

Trait Implementations

impl<B, H> Body for HtmlRewriteBody<B, H>

where B: Body, <B as Body>::Error: Into<Box<dyn Error + Sync + Send>>, H: ElementContentHandler,

type Data = Bytes

Values yielded by the Body.

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

The error type this Body might generate.

fn poll_frame( self: Pin<&mut HtmlRewriteBody<B, H>>, cx: &mut Context<'_>, ) -> Poll<Option<Result<Frame<<HtmlRewriteBody<B, H> as Body>::Data>, <HtmlRewriteBody<B, H> as Body>::Error>>>

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

fn size_hint(&self) -> SizeHint

Returns the bounds on the remaining length of the stream.

fn is_end_stream(&self) -> bool

Returns true when the end of stream has been reached.

impl<'__pin, B, H> Unpin for HtmlRewriteBody<B, H>

where <PinnedFieldsOfHelperStruct<__Origin<'__pin, B, H>> as PinnedFieldsOfHelperTrait>::Actual: Unpin,