Struct Buffer 

pub struct Buffer<R> { /* private fields */ }

Buffer - service factory for service that can buffer incoming request.

Default number of buffered requests is 16

Implementations

impl<R> Buffer<R>

pub fn buf_size(self, size: usize) -> Self

Set size of the buffer.

Default is set to 16

pub fn cancel_on_shutdown(self) -> Self

Cancel all buffered requests on shutdown.

By default buffered requests are flushed during poll_shutdown()

Trait Implementations

impl<R> Clone for Buffer<R>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<R> Debug for Buffer<R>

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

Formats the value using the given formatter.

impl<R> Default for Buffer<R>

fn default() -> Self

Returns the “default value” for a type.

impl<R, S, C> Middleware<S, C> for Buffer<R>

where S: Service<R> + 'static, R: 'static,

type Service = BufferService<R, S>

The middleware Service value created by this factory

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

Creates and returns a new middleware service.

fn apply<Fac, Req>( self, factory: Fac, ) -> ServiceChainFactory<ApplyMiddleware<Self, Fac, Cfg>, Req, Cfg>

where Fac: ServiceFactory<Req, Cfg, Service = Svc>, Cfg: Clone, Self: Sized, Self::Service: Service<Req>,

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