Struct WorkerLayer 

pub struct WorkerLayer<T> { /* private fields */ }

Layer that spawns a provided worker task using a closure that accepts a clone of the service and then passes through the wrapped service. Spawns a worker task with a clone of the inner service.

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<T> WorkerLayer<T>

pub fn new(make_worker: T) -> Self

Creates a new WorkerLayer with the provided make_worker closure.

make_worker accepts a clone of the inner service and returns a Future that will be spawned as a tokio task.

Trait Implementations

impl<S, T, F> Layer<S> for WorkerLayer<T>

where S: Clone, T: Fn(S) -> F, F: Future<Output = ()> + Send + 'static,

type Service = S

The wrapped service

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

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