Function sse_passthrough

uncommon_route/proxy.py:5546–5561

()

                    )

                async def sse_passthrough() -> AsyncGenerator[bytes, None]:
                    stream_chunks: list[bytes] = []
                    try:
                        async for chunk in stream_resp.aiter_bytes():
                            stream_chunks.append(chunk)
                            yield _normalize_reasoning_content_chunk(chunk)
                        await _record_stream_success(
                            parse_stream_usage_metrics(stream_chunks, selected_model, _get_pricing()),
                            stream_chunks=stream_chunks,
                        )
                    except Exception:
                        await _record_stream_failure()
                        raise
                    finally:
                        await _record_stream_aborted(stream_chunks=stream_chunks)
                        await stream_resp.aclose()

                return StreamingResponse(
                    sse_passthrough(),