Struct ContextService

pub struct ContextService<CXStore, T> {
    pub inner: T,
    pub ctx: PhantomData<CXStore>,
}

A service to insert Context into the request processing pipeline, compatible with certain_map.

Fields

inner: T

ctx: PhantomData<CXStore>

Implementations

impl<CX, F> ContextService<CX, F>

pub fn layer<C>() -> impl FactoryLayer<C, F, Factory = Self>

Trait Implementations

impl<CXStore, F: AsyncMakeService> AsyncMakeService for ContextService<CXStore, F>

type Service = ContextService<CXStore, <F as AsyncMakeService>::Service>

The type of service this factory creates.

type Error = <F as AsyncMakeService>::Error

The type of error that can occur during service creation.

async fn make_via_ref( &self, old: Option<&Self::Service>, ) -> Result<Self::Service, Self::Error>

Asynchronously creates a new service, optionally using an existing service as a reference.

fn make(&self) -> impl Future<Output = Result<Self::Service, Self::Error>>

Asynchronously creates a new service without referencing an existing one.

impl<CXStore, T> Clone for ContextService<CXStore, T>

where T: Clone,

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<CXStore: Debug, T: Debug> Debug for ContextService<CXStore, T>

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

Formats the value using the given formatter.

impl<CXStore, F: MakeService> MakeService for ContextService<CXStore, F>

type Service = ContextService<CXStore, <F as MakeService>::Service>

The type of service this factory creates.

type Error = <F as MakeService>::Error

The type of error that can occur during service creation.

fn make_via_ref( &self, old: Option<&Self::Service>, ) -> Result<Self::Service, Self::Error>

Creates a new service, optionally using an existing service as a reference.

fn make(&self) -> Result<Self::Service, Self::Error>

Creates a new service without referencing an existing one.

impl<R, T, CXStore, Resp, Err> Service<(R, AcceptedAddr)> for ContextService<CXStore, T>

where CXStore: Default + Handler, for<'a> CXStore::Hdr<'a>: ParamSet<PeerAddr>, for<'a> T: Service<(R, <CXStore::Hdr<'a> as ParamSet<PeerAddr>>::Transformed), Response = Resp, Error = Err>,

type Response = Resp

The type of response returned by this service.

type Error = Err

The type of error that this service can produce.

async fn call( &self, __arg1: (R, AcceptedAddr), ) -> Result<Self::Response, Self::Error>

Asynchronously process the request and return the response.

impl<CXStore, T> Copy for ContextService<CXStore, T>

where T: Copy,

impl<CXStore, T: Send> Send for ContextService<CXStore, T>

impl<CXStore, T: Sync> Sync for ContextService<CXStore, T>