code: def __init__(self, downstream: RayServeHandle):
      logging.getLogger("ray.serve").setLevel(logging.WARNING)
  
      self._h: DeploymentHandle = downstream.options(
          stream=True,
          use_new_handle_api=True,
      )
  
file_path: ray/python/ray/serve/_private/benchmarks/streaming/streaming_http_throughput.py
imports: import asyncio
  import logging
  from typing import Tuple
  import aiohttp
  import click
  from starlette.responses import StreamingResponse
  from ray import serve
  from ray.serve._private.benchmarks.common import run_throughput_benchmark
  from ray.serve.handle import DeploymentHandle, RayServeHandle
label_desc: Use image node_id 1 to create a new Intermediate object  with example: obj = Intermediate(downstream)