code: def stream(self):
      payload = PayloadPydantic(
          text="Test output",
          floats=[float(f) for f in range(1, 100)],
          ints=list(range(1, 100)),
          ts=time.time(),
          reason="Success!",
      )
  
      for i in range(self._tokens_per_request):
          yield payload
  
imports: import abc
  import asyncio
  import enum
  import logging
  import time
  from typing import Tuple, Union
  import numpy
  from ray.actor import ActorHandle
  from ray.runtime_env import RuntimeEnv
  from ray.serve._private.benchmarks.common import Blackhole, run_throughput_benchmark
  from ray.serve._private.benchmarks.serialization.common import PayloadPydantic
  from ray.serve.handle import DeploymentHandle
label_desc: Use image node_id 2 for calling the Endpoint obj's underlying member method code with example usage: obj.stream() without return types