Struct tower_buffer::BufferLayer

pub struct BufferLayer<Request, E = DefaultExecutor> { /* fields omitted */ }

Buffer requests with a bounded buffer

Methods

impl<Request> BufferLayer<Request, DefaultExecutor>

pub fn new(bound: usize) -> Self

impl<Request, E: Clone> BufferLayer<Request, E>

pub fn with_executor(bound: usize, executor: E) -> Self

Trait Implementations

impl<Request, E> Debug for BufferLayer<Request, E> where
    E: Debug, 

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

Formats the value using the given formatter.

impl<E, S, Request> Layer<S> for BufferLayer<Request, E> where
    S: Service<Request>,
    S::Error: Into<Box<dyn Error + Send + Sync>>,
    E: WorkerExecutor<S, Request> + Clone, 

type Service = Buffer<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.