Struct tonic::service::interceptor::InterceptedService

pub struct InterceptedService<S, F> { /* private fields */ }

A service wrapped in an interceptor middleware.

See Interceptor for more details.

Implementations

impl<S, F> InterceptedService<S, F>

pub fn new(service: S, f: F) -> Self

where F: Interceptor,

Create a new InterceptedService that wraps S and intercepts each request with the function F.

Trait Implementations

impl<S: Clone, F: Clone> Clone for InterceptedService<S, F>

fn clone(&self) -> InterceptedService<S, F>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<S, F> Debug for InterceptedService<S, F>

where S: Debug,

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

Formats the value using the given formatter.

impl<S, F> NamedService for InterceptedService<S, F>

where S: NamedService,

const NAME: &'static str = S::NAME

The Service-Name as described here.

impl<S, F, ReqBody, ResBody> Service<Request<ReqBody>> for InterceptedService<S, F>

where ResBody: Default + Body<Data = Bytes> + Send + 'static, F: Interceptor, S: Service<Request<ReqBody>, Response = Response<ResBody>>, S::Error: Into<Box<dyn Error + Send + Sync>>, ResBody::Error: Into<Box<dyn Error + Send + Sync>>,

type Response = Response<UnsyncBoxBody<Bytes, Status>>

Responses given by the service.

type Error = <S as Service<Request<ReqBody>>>::Error

Errors produced by the service.

type Future = ResponseFuture<<S as Service<Request<ReqBody>>>::Future>

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: Request<ReqBody>) -> Self::Future

Process the request and return the response asynchronously.

impl<S: Copy, F: Copy> Copy for InterceptedService<S, F>