Struct InFlightService

pub struct InFlightService { /* private fields */ }

Service that can limit number of in-flight async requests.

Default is 16 in-flight messages and 64kb size

Implementations

impl InFlightService

pub fn new(max_receive: u16, max_receive_size: usize) -> Self

Create new InFlightService middleware

By default max receive is 16 and max size is 64kb

pub fn max_receive(self, val: u16) -> Self

Number of inbound in-flight concurrent messages.

By default max receive number is set to 16 messages

pub fn max_receive_size(self, val: usize) -> Self

Total size of inbound in-flight messages.

By default total inbound in-flight size is set to 64Kb

Trait Implementations

impl Default for InFlightService

fn default() -> Self

Returns the “default value” for a type.

impl<S> Middleware<S> for InFlightService

type Service = InFlightServiceImpl<S>

The middleware Service value created by this factory

fn create(&self, service: S) -> Self::Service

Creates and returns a new middleware Service