Struct JsonRewriteBody 

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

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, ) -> Self

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, ) -> Self

Wraps inner with a custom tokenizer buffered-input limit.

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

pub fn passthrough(inner: B) -> Self

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) -> Self

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: StreamingBody<Error: Into<BoxError>>, H: JsonValueHandler,

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 Self>, cx: &mut Context<'_>, ) -> Poll<Option<Result<Frame<Self::Data>, Self::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 PinnedFieldsOf<__Origin<'__pin, B, H>>: Unpin,