code: def __init__(
      self,
      tempdir,
      socket_type,
      *,
      mode: IOMode,
      tokens_per_request: int,
      batch_size: int,
      num_trials: int,
      trial_runtime: float,
  ):
      super().__init__(
          self.create_downstream(socket_type, tempdir),
          mode=mode,
          tokens_per_request=tokens_per_request,
          batch_size=batch_size,
          num_trials=num_trials,
          trial_runtime=trial_runtime,
      )
  
file_path: ray/python/ray/serve/_private/benchmarks/streaming/streaming_grpc_throughput.py
imports: import asyncio
  import logging
  import time
  from concurrent import futures
  from tempfile import TemporaryDirectory
  import click
  import grpc
  import ray
  from ray.serve._private.benchmarks.streaming._grpc import test_server_pb2, test_server_pb2_grpc
  from ray.serve._private.benchmarks.streaming._grpc.grpc_server import TestGRPCServer
  from ray.serve._private.benchmarks.streaming.common import Caller, IOMode
label_desc: Use image node_id 1 to create a new GrpcCallerActor object from inherited base classes: Caller with example: obj = GrpcCallerActor(tempdir, socket_type)