Function anthropic_sse

uncommon_route/proxy.py:5516–5534

()

                    )

                    async def anthropic_sse() -> AsyncGenerator[bytes, None]:
                        stream_chunks: list[bytes] = []
                        try:
                            async for chunk in stream_resp.aiter_bytes():
                                stream_chunks.append(chunk)
                                for ev in converter.feed(chunk):
                                    yield ev
                            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_sse(),