class_docstr: Servicer handling RPCs for service statuses.
class_docstr_tok: ["Servicer","handling","RPCs","for","service","statuses","."]
code: def Watch(self, request, context, send_response_callback=None):
      blocking_watcher = None
      if send_response_callback is None:
          # The server does not support the experimental_non_blocking
          # parameter. For backwards compatibility, return a blocking response
          # generator.
          blocking_watcher = _Watcher()
          send_response_callback = (
              _watcher_to_send_response_callback_adapter(
                  blocking_watcher
              )
          )
      service = request.service
      with self._lock:
          status = self._server_status.get(service)
          if status is None:
              status = (
                  health_pb2.HealthCheckResponse.SERVICE_UNKNOWN
              )  # pylint: disable=no-member
          send_response_callback(
              health_pb2.HealthCheckResponse(status=status)
          )
          if service not in self._send_response_callbacks:
              self._send_response_callbacks[service] = set()
          self._send_response_callbacks[service].add(
              send_response_callback
          )
          context.add_callback(
              self._on_close_callback(send_response_callback, service)
          )
      return blocking_watcher
  
imports: import collections
  import threading
  from aim.ext.transport.proto import health_pb2
  from aim.ext.transport.proto import health_pb2_grpc
label_desc: Use image node_id 4 for calling the HealthServicer obj's underlying member method code with example usage: obj.Watch(request, context, send_response_callback) and returns: blocking_watcher