Struct SharedServiceAdapter

pub struct SharedServiceAdapter<T>(/* private fields */);

Adapter to use a tower::Service as a rama::Service, sharing the service between each request it has to serve.

Note that:

• you should use ServiceAdapter in case you do not want it to be shared, and prefer it to be Cloned instead, which is anyway the more “normal” scenario;
• you are required to use the LayerServiceAdapter for tower layer services, which will automatically be the case if you use LayerAdapter to wrap a tower::Layer.

Halting

This adapter assumes that a service will always become ready eventually, as it will call poll_ready until ready prior to calling the tower::Service. Please ensure that your tower::Service does not require a side-step to prevent such halting.

Implementations

impl<T: Send + Sync + 'static> SharedServiceAdapter<T>

pub fn new(svc: T) -> Self

Adapt a shared tower::Service into a rama::Service.

See SharedServiceAdapter for more information.

Trait Implementations

impl<T> Clone for SharedServiceAdapter<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for SharedServiceAdapter<T>

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

Formats the value using the given formatter.

impl<T, State, Request> Service<State, Request> for SharedServiceAdapter<T>

where T: TowerService<Request, Response: Send + 'static, Error: Send + 'static, Future: Send> + Send + Sync + 'static, State: Clone + Send + Sync + 'static, Request: Send + 'static,

type Response = <T as Service<Request>>::Response

The type of response returned by the service.

type Error = <T as Service<Request>>::Error

The type of error returned by the service.

fn serve( &self, _ctx: Context<State>, req: Request, ) -> impl Future<Output = Result<Self::Response, Self::Error>> + Send + '_

Serve a response or error for the given request, using the given context.

fn boxed(self) -> BoxService<S, Request, Self::Response, Self::Error>

Box this service to allow for dynamic dispatch.