Struct RoutingPipe 

pub struct RoutingPipe<Handle = PipeHandle> { /* private fields */ }

Pattern-routed dispatcher. Generic over the handle: RoutingPipe<PipeHandle> impls Handler; RoutingPipe<ThreadLocalPipeHandle> impls ThreadLocalHandler.

Implementations

impl<Handle> RoutingPipe<Handle>

pub fn new(label: impl Into<String>) -> Self

pub fn route(self, pattern: &str, pipe: Handle) -> Self

pub fn route_with_methods( self, pattern: &str, pipe: Handle, methods: MethodFilter, ) -> Self

pub fn fallback(self, pipe: Handle) -> Self

pub fn label(&self) -> &str

The routing pipe’s own label (set at construction, not a mount-site name — this labels the RoutingPipe node itself, e.g. for tracing).

Trait Implementations

impl Pipe for RoutingPipe<ThreadLocalPipeHandle>

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, request: Request<Bytes>, ) -> impl Future<Output = Result<Response<Bytes>, ProximaError>>

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

impl<Handle> SendPipe for RoutingPipe<Handle>

where Handle: Handler + 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 — Send here so it can cross cores.

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

Apply the pipe. The returned future IS Send.