code: def _watcher_to_send_response_callback_adapter(watcher):
      def send_response_callback(response):
          if response is None:
              watcher.close()
          else:
              watcher.add(response)
  
      return send_response_callback
  
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 1 for calling a global function with example usage: _watcher_to_send_response_callback_adapter(watcher) and returns: send_response_callback