Asynchrone StreamingHttpResponse mittels Generator-Ausnahmeweiterleitung

import asyncio
from typing import AsyncGenerator
from django.http import StreamingHttpResponse
 
async def generate_telemetry_stream() -> AsyncGenerator[str, None]:
    try:
        for step in range(5):
            await asyncio.sleep(0.1)
            yield f"event: metric\ndata: {{\"step\": {step}}}\n\n"
    except asyncio.CancelledError:
        # Clean up socket resources on client disconnect
        pass
 
async def telemetry_stream_view(request):
    return StreamingHttpResponse(
        generate_telemetry_stream(),
        content_type="text/event-stream"
    )