Struct JsonRewrite 

pub struct JsonRewrite<S, H> { /* private fields */ }

Available on crate features http and std only.

Rewrites JSON response bodies of the underlying service, using rama’s streaming JsonRewriter.

See the module docs for details. Construct it directly with new or via JsonRewriteLayer.

Implementations

impl<S, H> JsonRewrite<S, H>

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

Creates a new JsonRewrite service.

The selector index passed to the handler is the index into selectors; keep the two aligned.

pub fn with_rewrite_policy( self, policy: impl Fn(&HeaderMap, &Extensions) -> bool + Send + Sync + 'static, ) -> JsonRewrite<S, H>

Sets a custom response rewrite policy.

The predicate receives the response headers and extensions and can narrow rewriting beyond the built-in Content-Encoding guard.

pub fn set_rewrite_policy( &mut self, policy: impl Fn(&HeaderMap, &Extensions) -> bool + Send + Sync + 'static, ) -> &mut JsonRewrite<S, H>

Sets a custom response rewrite policy.

The predicate receives the response headers and extensions and can narrow rewriting beyond the built-in Content-Encoding guard.

pub fn with_max_buffered_bytes( self, max_buffered_bytes: usize, ) -> JsonRewrite<S, H>

Sets the tokenizer buffered-input limit for each rewritten body.

pub fn set_max_buffered_bytes( &mut self, max_buffered_bytes: usize, ) -> &mut JsonRewrite<S, H>

Sets the tokenizer buffered-input limit for each rewritten body.

pub fn get_ref(&self) -> &S

Gets a reference to the underlying service.

pub fn into_inner(self) -> S

Consumes self, returning the underlying service.

Trait Implementations

impl<S, H> Clone for JsonRewrite<S, H>

where S: Clone, H: Clone,

fn clone(&self) -> JsonRewrite<S, H>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<S, H> Debug for JsonRewrite<S, H>

where S: Debug,

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

Formats the value using the given formatter.

impl<S, H, ReqBody, ResBody> Service<Request<ReqBody>> for JsonRewrite<S, H>

where S: Service<Request<ReqBody>, Output = Response<ResBody>>, ResBody: Body + Send + 'static, <ResBody as Body>::Data: Send + 'static, <ResBody as Body>::Error: Into<Box<dyn Error + Send + Sync>> + Send + 'static, H: JsonValueHandler + Clone + Send + Sync + 'static, ReqBody: Send + 'static,

type Output = Response<JsonRewriteBody<ResBody, H>>

The type of the output returned by the service.

type Error = <S as Service<Request<ReqBody>>>::Error

The type of error returned by the service.

async fn serve( &self, req: Request<ReqBody>, ) -> Result<<JsonRewrite<S, H> as Service<Request<ReqBody>>>::Output, <JsonRewrite<S, H> as Service<Request<ReqBody>>>::Error>

Serve an output or an error for the given input

fn boxed(self) -> BoxService<Input, Self::Output, Self::Error>

Box this service to allow for dynamic dispatch.