code: def __init__(self, streamer: DeploymentHandle):
      self._streamer = streamer.options(
          # Must set `stream=True` on the handle, then the output will be a
          # response generator.
          stream=True,
      )
  
imports: from typing import AsyncGenerator, Generator
  from ray import serve
  from ray.serve.handle import DeploymentHandle, DeploymentResponseGenerator
label_desc: Use image node_id 1 to create a new Caller object  with example: obj = Caller(streamer)