code: def test_exception_raised_in_gen(
      self, serve_instance, deployment: Deployment
  ):
      @serve.deployment
      class Delegate:
          def __init__(self, streamer: RayServeHandle):
              self._h = streamer
  
          async def __call__(self):
              h = self._h.options(stream=True)
  
              gen = h.remote(0, should_error=True)
              with pytest.raises(RuntimeError, match="oopsies"):
                  await gen.__anext__()
  
      h = serve.run(Delegate.bind(deployment.bind()))
      h.remote().result()
  
imports: import sys
  from typing import AsyncGenerator, Generator
  import pytest
  from ray import serve
  from ray.serve import Deployment
  from ray.serve.handle import RayServeHandle
label_desc: Use image node_id 5 for calling the TestDeploymentHandleStreaming obj's underlying member method code with example usage: obj.test_exception_raised_in_gen(serve_instance, deployment) without return types