Struct RequestPipeline 

pub struct RequestPipeline { /* private fields */ }

Sequential runner for a chain of ContextServices. The pipeline owns the services and threads a Context through them one after another, short-circuiting on the first error.

This replaces the legacy MiddlewareRegistry::process loop.

Implementations

impl RequestPipeline

pub const fn new() -> Self

Create an empty pipeline.

pub const fn from_services(services: Vec<ContextService>) -> Self

Build a pipeline from a vec of services.

pub fn push(&mut self, svc: ContextService)

Push a service onto the end of the pipeline.

pub const fn len(&self) -> usize

Number of registered services.

pub const fn is_empty(&self) -> bool

Whether the pipeline has no services registered.

pub async fn run(&mut self, ctx: Context) -> Result<Context>

Run every service in registration order, threading the Context through. Returns the final Context once the chain completes, or the first YetiError.

Errors

Surfaces the first Err returned by any registered service. Subsequent services are skipped.

pub fn services(&self) -> &[ContextService]

Borrow the underlying service vector (for snapshots / cloning).

pub fn into_composed(self) -> ContextService

Compose every registered service into a single ContextService. Per-request the host clones the composed service (one Arc bump) and calls it once — versus the unfrozen path which clones every service per request and allocates a Vec. Used by the router’s freeze_middleware to build the hot-path snapshot.

Trait Implementations

impl Debug for RequestPipeline

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

Formats the value using the given formatter.

impl Default for RequestPipeline

fn default() -> Self

Returns the “default value” for a type.