Function responses_sse

uncommon_route/proxy.py:5878–5887

()

            )

            async def responses_sse() -> AsyncGenerator[bytes, None]:
                async for chunk in upstream_resp.body_iterator:
                    adapter.feed(chunk)
                events, assistant_message = adapter.finalize()
                if assistant_message is not None:
                    _responses_history[response_id] = json.loads(
                        json.dumps(chat_messages + [assistant_message])
                    )
                for event in events:
                    yield event

            headers = {
                key: value