Struct BatchLayer 

pub struct BatchLayer<Request> { /* private fields */ }

A Layer that wraps an inner service with Batch.

The background worker is spawned on the default Tokio executor, so this layer can only be used on the Tokio runtime.

See the module documentation for the full lifecycle and error semantics.

Implementations

impl<Request> BatchLayer<Request>

pub fn new(size: usize, time: Duration) -> Self

Creates a new BatchLayer.

• size – the maximum number of items per batch.
• time – the maximum duration before a batch is flushed.

Trait Implementations

impl<Request> Debug for BatchLayer<Request>

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

Formats the value using the given formatter.

impl<S, Request> Layer<S> for BatchLayer<Request>

where S: Service<BatchControl<Request>> + Send + 'static, S::Future: Send, S::Error: Into<BoxError> + Send + Sync, Request: Send + 'static,

type Service = Batch<S, Request>

The wrapped service

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

Wrap the given service with the middleware, returning a new service that has been decorated with the middleware.