Struct BatchLayer 

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

Adds a layer performing batch processing of requests.

The default Tokio executor is used to run the given service, which means that this layer can only be used on the Tokio runtime.

See the module documentation for more details.

Implementations

impl<Request> BatchLayer<Request>

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

Creates a new BatchLayer.

The wrapper is responsible for telling the inner service when to flush a batch of requests. Two parameters control this policy:

• size gives the maximum number of items per batch.
• time gives 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.