Function anthropic_native_sse

uncommon_route/proxy.py:5473–5496

()

                if native_anthropic_transport:
                    async def anthropic_native_sse() -> AsyncGenerator[bytes, None]:
                        stream_chunks: list[bytes] = []
                        converter = None if api_format == "anthropic" else AnthropicToOpenAIStreamConverter(model=selected_model)
                        try:
                            async for chunk in stream_resp.aiter_bytes():
                                stream_chunks.append(chunk)
                                if converter is None:
                                    yield chunk
                                else:
                                    for ev in converter.feed(chunk):
                                        yield ev
                            if converter is not None:
                                for ev in converter.finish():
                                    yield ev
                            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(
                        anthropic_native_sse(),