Struct FilterConfig 

pub struct FilterConfig<In = Request<Bytes>, Err = ProximaError> {
    pub predicate: Predicate<In, Err>,
    pub on_reject: RejectMode,
}

The predicate-gated pass/reject decision, as config and as the pipe itself: FilterConfig is both the 1:1 serialisable mirror AND the SendPipe/Pipe implementor (In -> Result<In, Err>, generic over both like Predicate) — its two fields are exactly what a decision needs (the gate, and which error a reject produces), so no separate combinator carries them, and no separate type is needed to use it at a payload of the caller’s own: FilterConfig { predicate, on_reject }.and_then(inner) composes at any In/Err the same way Predicate does. Only FilterConfig::into_filter/FilterConfig::from_spec stay pinned to this crate’s HTTP PipeHandle, because PipeFactory’s own signature is pinned there — not a constraint this module introduces.

Fields

predicate: Predicate<In, Err>

on_reject: RejectMode

Implementations

impl FilterConfig<Request<Bytes>, ProximaError>

pub fn into_filter(self, inner: PipeHandle) -> PipeHandle

Compose the decision in front of inner and erase — predicate. and_then(inner) in one call, matching every other into_* factory entry point in this crate (Delay::into_delay, Transform:: into_transform, …).

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

Trait Implementations

impl<In, Err> Clone for FilterConfig<In, Err>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<In, Err> Debug for FilterConfig<In, Err>

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

Formats the value using the given formatter.

impl<In, Err> Default for FilterConfig<In, Err>

fn default() -> Self

Returns the “default value” for a type.

impl<'de, In, Err> Deserialize<'de> for FilterConfig<In, Err>

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<In, Err> PartialEq for FilterConfig<In, Err>

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl<In, Err> Pipe for FilterConfig<In, Err>

where In: 'static, Err: From<RejectMode> + Debug + 'static,

type In = In

Input the pipe consumes.

type Out = In

Output the pipe produces.

type Err = Err

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

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

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

impl<In, Err> SendPipe for FilterConfig<In, Err>

where In: Send + 'static, Err: From<RejectMode> + Debug + Send + 'static,

type In = In

Input the pipe consumes.

type Out = In

Output the pipe produces.

type Err = Err

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

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

Apply the pipe. The returned future IS Send.

impl<In, Err> Serialize for FilterConfig<In, Err>

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl<In, Err> UnpinPipe for FilterConfig<In, Err>

where In: 'static, Err: From<RejectMode> + Debug + 'static,

type In = In

Input the pipe consumes.

type Out = In

Output the pipe produces.

type Err = Err

Error the pipe can fail with.

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

Apply the pipe. The returned future IS Unpin — pollable in place.

impl<In, Err> UnpinSendPipe for FilterConfig<In, Err>

where In: Send + 'static, Err: From<RejectMode> + Debug + Send + 'static,

type In = In

Input the pipe consumes.

type Out = In

Output the pipe produces.

type Err = Err

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

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

Apply the pipe. The returned future is Send AND Unpin.