update behaivor to catch StopAsyncIteration

Author: RenameMe1

litestar/response/streaming.py

@@ -151,15 +151,12 @@ async def _stream_with_timeout_events(self, send: Send) -> None:
         """
         while True:
             start_time = time.perf_counter()
+            chunk = self.iterator.__anext__()
+            task = asyncio.create_task(chunk)
 
-            try:
-                event = asyncio.create_task(self.iterator.__anext__())
-            except ValueError:
-                break
-
-            while not event.done():
+            while not task.done():
                 execution_time = time.perf_counter() - start_time
-                await asyncio.sleep(1)
+                await asyncio.sleep(0.01)
 
                 if execution_time >= self.timeout:
                     start_time = time.perf_counter()
@@ -168,11 +165,11 @@ async def _stream_with_timeout_events(self, send: Send) -> None:
                         "body": b"timeout ping\n",
                         "more_body": True,
                     }
-                    await send(stream_event)
 
-            start_time = time.perf_counter()
-
-            chunk = event.result()
+            try:
+                chunk = task.result()
+            except StopAsyncIteration:
+                break
 
             stream_event: HTTPResponseBodyEvent = {
                 "type": "http.response.body",