code: def disconnect_task_and_event() -> Tuple[asyncio.Event, asyncio.Task]:
      """Return an event and a task waiting on it for testing disconnect logic."""
      event = asyncio.Event()
  
      async def wait_for_event():
          return await event.wait()
  
      return event, asyncio.ensure_future(wait_for_event())
  
file_path: ray/python/ray/serve/tests/test_proxy_response_generator.py
imports: import asyncio
  from typing import AsyncIterator, Tuple
  import pytest
  from ray import serve
  from ray._private.test_utils import SignalActor, async_wait_for_condition
  from ray.serve._private.proxy_response_generator import ProxyResponseGenerator
label_desc: Use image node_id 1 for calling a global function with example usage: disconnect_task_and_event() and returns: event,  asyncio, unknown