Trait tower_buffer::WorkerExecutor

pub trait WorkerExecutor<T, Request>: TypedExecutor<Worker<T, Request>> where
    T: Service<Request>,
    T::Error: Into<Box<dyn Error + Send + Sync>>, { }

This trait allows you to use either Tokio's threaded runtime's executor or the current_thread runtime's executor depending on if T is Send or !Send.

Implementors

impl<T, Request, E: TypedExecutor<Worker<T, Request>>> WorkerExecutor<T, Request> for E where
    T: Service<Request>,
    T::Error: Into<Box<dyn Error + Send + Sync>>, 

Loading content...