Struct JsonCaptureBody 

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

A body that feeds the inner body’s bytes through a JsonCapturer, forwarding the body unchanged as Bytes.

Build it directly with new. Attach on_end to recover the handler and any state it accumulated once the body finishes cleanly.

Implementations

impl<B, H> JsonCaptureBody<B, H>

where H: CaptureHandler,

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

Wraps inner, capturing values matching selectors with handler.

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

Wraps inner with a custom tokenizer buffered-input limit.

impl<B, H> JsonCaptureBody<B, H>

pub fn passthrough(inner: B) -> Self

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

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 capture ends - for reading state it accumulated.

Fires once after JsonCapturer::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 JsonCaptureBody<B, H>

where B: StreamingBody<Error: Into<BoxError>>, H: CaptureHandler,

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 JsonCaptureBody<B, H>

where PinnedFieldsOf<__Origin<'__pin, B, H>>: Unpin,