Struct Transform 

pub struct Transform<Inner = PipeHandle, InOp = RequestOp, OutOp = ResponseOp> {
    pub inner: Inner,
    /* private fields */
}

Request/response transformation middleware. Generic over the inner pipe AND the op types; the std default type parameters (the HTTP RequestOp / ResponseOp, which carry regex::Regex) keep all existing call sites unchanged. Under no_std+alloc the HTTP op types are absent, so the defaults fall back to (); callers name their own op types explicitly.

Fields

inner: Inner

Implementations

impl<Inner, InOp, OutOp> Transform<Inner, InOp, OutOp>

pub fn new(inner: Inner) -> Self

pub fn with_request_op(self, op: InOp) -> Self

pub fn with_response_op(self, op: OutOp) -> Self

impl Transform<PipeHandle>

pub fn from_spec(inner: PipeHandle, value: &Value) -> Result<Self, ProximaError>

Trait Implementations

impl<InOp, OutOp> Pipe for Transform<ThreadLocalPipeHandle, InOp, OutOp>

where Request<Bytes>: ApplyOps<InOp>, Response<Bytes>: ApplyOps<OutOp>, InOp: Clone + Send + Sync + 'static, OutOp: Clone + Send + Sync + 'static,

type In = Request<Bytes>

Input the pipe consumes.

type Out = Response<Bytes>

Output the pipe produces.

type Err = ProximaError

Error the pipe can fail with. Debug + 'static; Send is added only on the cross-core SendPipe form.

fn call( &self, input: Request<Bytes>, ) -> impl Future<Output = Result<Response<Bytes>, ProximaError>>

Apply the pipe. The returned future is NOT required to be Send.

impl<Inner, InOp, OutOp> SendPipe for Transform<Inner, InOp, OutOp>

where Inner: SendPipe + Clone, Inner::In: ApplyOps<InOp> + Send, Inner::Out: ApplyOps<OutOp>, Inner::Err: Send, InOp: Clone + Send + Sync + 'static, OutOp: Clone + Send + Sync + 'static,

type In = <Inner as SendPipe>::In

Input the pipe consumes.

type Out = <Inner as SendPipe>::Out

Output the pipe produces.

type Err = <Inner as SendPipe>::Err

Error the pipe can fail with — Send here so it can cross cores.

fn call( &self, input: Inner::In, ) -> impl Future<Output = Result<Inner::Out, Inner::Err>> + Send

Apply the pipe. The returned future IS Send.