Struct JsonRewriteBody 

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

Available on crate features http and std only.

A body that feeds the inner body’s bytes through a JsonRewriter, emitting rewritten chunks as they become available.

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

Implementations

impl<B, H> JsonRewriteBody<B, H>

where H: JsonValueHandler,

pub fn new( inner: B, selectors: impl IntoIterator<Item = JsonPath>, handler: H, ) -> JsonRewriteBody<B, H>

Wraps inner, rewriting values matching selectors with handler.

pub fn with_max_buffered_bytes( inner: B, selectors: impl IntoIterator<Item = JsonPath>, handler: H, max_buffered_bytes: usize, ) -> JsonRewriteBody<B, H>

Wraps inner with a custom tokenizer buffered-input limit.

impl<B, H> JsonRewriteBody<B, H>

pub fn passthrough(inner: B) -> JsonRewriteBody<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-JSON content type).

pub fn on_end<F>(self, on_end: F) -> JsonRewriteBody<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 JsonRewriter::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 JsonRewriteBody<B, H>

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

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 JsonRewriteBody<B, H>>, cx: &mut Context<'_>, ) -> Poll<Option<Result<Frame<<JsonRewriteBody<B, H> as Body>::Data>, <JsonRewriteBody<B, H> as Body>::Error>>>

Attempt to pull out the next frame of this stream.

fn size_hint(&self) -> SizeHint

A hint that returns the bounds on the remaining length of the stream.

fn is_end_stream(&self) -> bool

A hint that may return true when the end of stream has been reached.

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

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