pub fn into_interceptor(
        self,
    ) -> impl FnMut(Request<()>) -> Result<Request<()>, Status> + Clone {
        move |req| match self.get() {
            ServingReadinessState::Unavailable => {
                Err(Status::unavailable("service not ready to serve"))
            }
            ServingReadinessState::Serving => Ok(req),
        }
    }
/// Implements the gRPC interceptor that returns SERVICE_UNAVAILABLE gRPC status
/// if the service is not ready.
Implements the gRPC interceptor that returns SERVICE_UNAVAILABLE gRPC status
if the service is not ready.
Implements the gRPC interceptor that returns SERVICE_UNAVAILABLE gRPC status if the service is not ready .
pub fn into_interceptor(
        self,
    ) -> impl FnMut(Request<()>) -> Result<Request<()>, Status> + Clone {
        move |req| match self.get() {
            ServingReadinessState::Unavailable => {
                Err(Status::unavailable("service not ready to serve"))
            }
            ServingReadinessState::Serving => Ok(req),
        }
    }
pub fn into_interceptor ( self , ) -> impl FnMut ( Request < ( ) > ) -> Result < Request < ( ) > , Status > + Clone { move | req | match self . get ( ) { ServingReadinessState :: Unavailable => { Err ( Status :: unavailable ( " " ) ) } ServingReadinessState :: Serving => Ok ( req ) , } }
Implements the gRPC interceptor that returns SERVICE_UNAVAILABLE gRPC status
if the service is not ready.
Implements the gRPC interceptor that returns SERVICE_UNAVAILABLE gRPC status if the service is not ready .
self
self