code: def async_send_infer(self, request: str):
      if self._stream is None:
          raise RuntimeError("InferStream2 was already closed")
  
      self._stream.enqueue_request(request)
  
imports: import argparse
  import queue
  import threading
  from functools import partial
  import grpc
  import inference_pb2
  import inference_pb2_grpc
  import management_pb2
  import management_pb2_grpc
label_desc: Use image node_id 4 for calling the InferStream2SimpleClient obj's underlying member method code with example usage: obj.async_send_infer(request) without return types