Struct tower_buffer::Buffer [−][src]
Adds a buffer in front of an inner service.
See crate level documentation for more details.
Implementations
impl<T, Request> Buffer<T, Request> where
T: Service<Request>,
T::Error: Into<Box<dyn Error + Send + Sync>>,
[src][−]
T: Service<Request>,
T::Error: Into<Box<dyn Error + Send + Sync>>,
pub fn new(service: T, bound: usize) -> Self where
T: Send + 'static,
T::Future: Send,
T::Error: Send + Sync,
Request: Send + 'static,
[src][−]
T: Send + 'static,
T::Future: Send,
T::Error: Send + Sync,
Request: Send + 'static,
Creates a new Buffer
wrapping service
.
bound
gives the maximal number of requests that can be queued for the service before
backpressure is applied to callers.
The default Tokio executor is used to run the given service, which means that this method must be called while on the Tokio runtime.
pub fn pair(
service: T,
bound: usize
) -> (Buffer<T, Request>, Worker<T, Request>) where
T: Send + 'static,
T::Error: Send + Sync,
Request: Send + 'static,
[src][−]
service: T,
bound: usize
) -> (Buffer<T, Request>, Worker<T, Request>) where
T: Send + 'static,
T::Error: Send + Sync,
Request: Send + 'static,
Creates a new Buffer
wrapping service
but returns the background worker.
This is useful if you do not want to spawn directly onto the tokio
runtime
but instead want to use your own executor. This will return the Buffer
and
the background Worker
that you can then spawn.
Trait Implementations
impl<T, Request> Clone for Buffer<T, Request> where
T: Service<Request>,
[src][+]
T: Service<Request>,
impl<T: Debug, Request: Debug> Debug for Buffer<T, Request> where
T: Service<Request>,
T::Future: Debug,
[src][+]
T: Service<Request>,
T::Future: Debug,
impl<T, Request> Service<Request> for Buffer<T, Request> where
T: Service<Request>,
T::Error: Into<Box<dyn Error + Send + Sync>>,
[src][+]
T: Service<Request>,
T::Error: Into<Box<dyn Error + Send + Sync>>,
Auto Trait Implementations
impl<T, Request> !RefUnwindSafe for Buffer<T, Request>
impl<T, Request> Send for Buffer<T, Request> where
Request: Send,
<T as Service<Request>>::Future: Send,
Request: Send,
<T as Service<Request>>::Future: Send,
impl<T, Request> Sync for Buffer<T, Request> where
Request: Send,
<T as Service<Request>>::Future: Send,
Request: Send,
<T as Service<Request>>::Future: Send,
impl<T, Request> Unpin for Buffer<T, Request>
impl<T, Request> !UnwindSafe for Buffer<T, Request>
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src][+]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src][+]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src][+]
T: ?Sized,
impl<T> From<T> for T
[src][+]
impl<T> Instrument for T
[src][+]
impl<T, U> Into<U> for T where
U: From<T>,
[src][+]
U: From<T>,
impl<T> ToOwned for T where
T: Clone,
[src][+]
T: Clone,
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src][+]
U: Into<T>,
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src][+]
U: TryFrom<T>,