Struct qcs_api_client_grpc::channel::RefreshService

pub struct RefreshService<S: GrpcService<BoxBody>, T: TokenRefresher> { /* private fields */ }

The GrpcService that wraps the gRPC client in order to provide QCS authentication.

See also: RefreshLayer.

Trait Implementations

impl<S: Clone + GrpcService<BoxBody>, T: Clone + TokenRefresher> Clone for RefreshService<S, T>

fn clone(&self) -> RefreshService<S, T>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<S, T> GrpcService<UnsyncBoxBody<Bytes, Status>> for RefreshService<S, T>

where S: GrpcService<BoxBody> + Clone + Send + 'static, <S as GrpcService<BoxBody>>::Future: Send, <S as GrpcService<BoxBody>>::ResponseBody: Send, T: TokenRefresher + Clone + Send + Sync + 'static, T::Error: Error + Send + Sync, Error<T::Error>: From<S::Error>,

type ResponseBody = <S as GrpcService<UnsyncBoxBody<Bytes, Status>>>::ResponseBody

Responses body given by the service.

type Error = Error<<T as TokenRefresher>::Error>

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<Response<<RefreshService<S, T> as GrpcService<UnsyncBoxBody<Bytes, Status>>>::ResponseBody>, <RefreshService<S, T> as GrpcService<UnsyncBoxBody<Bytes, Status>>>::Error>> + Send>>

The future response value.

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

Returns Ready when the service is able to process requests.

fn call(&mut self, req: Request<BoxBody>) -> Self::Future

Process the request and return the response asynchronously.