Struct InFlight 

pub struct InFlight { /* private fields */ }

Middleware that limits the number of concurrent calls to a service.

Readiness remains pending while every slot is in use. The default limit is 15 concurrent calls.

Implementations

impl InFlight

pub fn new(max: usize) -> InFlight

Creates middleware with the specified concurrency limit.

A limit of zero keeps the service permanently unavailable.

Trait Implementations

impl Clone for InFlight

fn clone(&self) -> InFlight

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for InFlight

impl Debug for InFlight

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

Formats the value using the given formatter.

impl Default for InFlight

fn default() -> InFlight

Returns the “default value” for a type.

impl<S, St> Middleware<S, St> for InFlight

type Service = InFlightService<S>

Service created by this middleware.

fn create(&self, _: &St, service: S) -> <InFlight as Middleware<S, St>>::Service

Creates and returns a new middleware service.

fn apply_to<Sf, Req>( self, factory: Sf, ) -> ServiceChainFactory<ApplyMiddleware<Self, Sf>, St, Req>

where Sf: ServiceFactory<St, Req, Service = S>, Self: Sized, Self::Service: Service<St, Req>,

Creates a service factory that instantiates a service and applies the current middleware to it.