code: def __call__(self, *args):
      return StreamingResponse(self.stream())
  
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 2 for calling the Downstream obj's underlying member method code with example usage: obj.__call__() and returns: StreamingResponse