Struct Buffer 

pub struct Buffer<St, Req, Res, Err>
where
    St: Clone,
{ /* private fields */ }

Middleware that buffers requests while the wrapped service is not ready.

See BufferService for how buffered requests are released.

The default buffer capacity is 16 requests.

Implementations

impl<St, Req, Res, Err> Buffer<St, Req, Res, Err>

where St: Clone,

pub fn buf_size(self, size: usize) -> Buffer<St, Req, Res, Err>

Sets the maximum number of buffered requests.

The default capacity is 16.

pub fn cancel_on_shutdown(self) -> Buffer<St, Req, Res, Err>

Cancel all buffered requests on shutdown.

By default, buffered requests are released during service shutdown.

Trait Implementations

impl<St, Req, Res, Err> Clone for Buffer<St, Req, Res, Err>

where St: Clone, Req: Clone, Res: Clone, Err: Clone,

fn clone(&self) -> Buffer<St, Req, Res, Err>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<St, Req, Res, Err> Copy for Buffer<St, Req, Res, Err>

where St: Copy + Clone, Req: Copy, Res: Copy, Err: Copy,

impl<St, Req, Res, Err> Debug for Buffer<St, Req, Res, Err>

where St: Debug + Clone, Req: Debug, Res: Debug, Err: Debug,

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

Formats the value using the given formatter.

impl<St, Req, Res, Err> Default for Buffer<St, Req, Res, Err>

where St: Clone,

fn default() -> Buffer<St, Req, Res, Err>

Returns the “default value” for a type.

impl<S, St, Req, Res, Err> Middleware<S, St> for Buffer<St, Req, Res, Err>

where S: Service<St, Req, Res = Res, Error = Err> + 'static, St: Clone + 'static, Req: 'static, Res: 'static, Err: 'static,

type Service = BufferService<St, Req, Res, Err>

Service created by this middleware.

fn create( &self, _: &St, service: S, ) -> <Buffer<St, Req, Res, Err> 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.