Function _record_stream_aborted

uncommon_route/proxy.py:5372–5389

(
                    stream_chunks: list[bytes] | None = None,
                )

                    stream_record_state["done"] = True

                async def _record_stream_aborted(
                    stream_chunks: list[bytes] | None = None,
                ) -> None:
                    if stream_record_state["done"]:
                        return
                    try:
                        await _spend_reservation.release(request_id)
                    except Exception:
                        pass
                    _record_route_trace(
                        status_code=499,
                        streaming=True,
                        error_code="client_disconnected",
                        error_stage="stream",
                        error_message="Client closed connection before stream finalized",
                        stream_chunks=stream_chunks,
                    )
                    stream_record_state["done"] = True

                async def _open_stream_attempt(attempt_payload: dict[str, Any]) -> httpx.Response:
                    client = _get_client()