Struct SharedService

pub struct SharedService<T, U, E>(/* private fields */);

A Service that can be cloned, sent, and shared across threads.

Implementations

impl<T, U, E> SharedService<T, U, E>

pub fn new<S>(service: S) -> Self

where S: Service<T, Response = U, Error = E> + Clone + Send + Sync + 'static, S::Future: Send + 'static,

Create a new SharedService from a Service.

pub fn layer<S>() -> impl Layer<S, Service = SharedService<T, U, E>>

where S: Service<T, Response = U, Error = E> + Clone + Send + Sync + 'static, S::Future: Send + 'static,

Create a layer which wraps a Service in a SharedService.

Trait Implementations

impl<T, U, E> Clone for SharedService<T, U, E>

fn clone(&self) -> Self

Returns a duplicate of the value.

const fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T, U, E> Debug for SharedService<T, U, E>

fn fmt(&self, fmt: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T, U, E> Service<T> for SharedService<T, U, E>

type Response = U

Responses given by the service.

type Error = E

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<U, E>> + Send>>

The future response value.

fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, req: T) -> Self::Future

Process the request and return the response asynchronously.