code: def intercept_service(self, continuation, handler_call_details):
          
          rpc_method_handler = self._get_rpc_handler(handler_call_details)
          if rpc_method_handler.response_streaming:
              if self._wrapped.is_streaming:
                  # `self._wrapped` is a `StreamServerInterceptor`
                  return self._wrapped.intercept_service(
                      continuation, handler_call_details)
          else:
              if not self._wrapped.is_streaming:
                  # `self._wrapped` is a `UnaryServerInterceptor`
                  return self._wrapped.intercept_service(
                      continuation, handler_call_details)
  
          # skip the interceptor due to type mismatch
          return continuation(handler_call_details)
docs: Intercepts incoming RPCs before handing them over to a handler
  
          See `grpc.ServerInterceptor.intercept_service`.