Function _open_stream_attempt

uncommon_route/proxy.py:5391–5399

(attempt_payload: dict[str, Any])

                    stream_record_state["done"] = True

                async def _open_stream_attempt(attempt_payload: dict[str, Any]) -> httpx.Response:
                    client = _get_client()
                    req = client.build_request(
                        "POST",
                        attempt_payload["target_chat_url"],
                        json=attempt_payload["transport_body"],
                        headers=attempt_payload["headers"],
                    )
                    return await client.send(req, stream=True)

                async def _select_stream_response() -> tuple[httpx.Response | None, Response | None]:
                    fallback_source_model: str | None = None