Skip to content

ccproxy.llms.formatters.openai_to_anthropic.streams

ccproxy.llms.formatters.openai_to_anthropic.streams

OpenAI→Anthropic streaming conversion entry points.

OpenAIResponsesToAnthropicStreamAdapter

Stateful adapter for OpenAI Responses → Anthropic streaming.

OpenAIChatToAnthropicStreamAdapter

Stateful adapter for OpenAI Chat → Anthropic streaming.

convert__openai_responses_to_anthropic_messages__stream async 

convert__openai_responses_to_anthropic_messages__stream(
    stream,
)

Translate OpenAI Responses streaming events into Anthropic message events.

Source code in ccproxy/llms/formatters/openai_to_anthropic/streams.py 
506
507
508
509
510
511
512
513
async def convert__openai_responses_to_anthropic_messages__stream(
    stream: AsyncIterator[Any],
) -> AsyncGenerator[anthropic_models.MessageStreamEvent, None]:
    """Translate OpenAI Responses streaming events into Anthropic message events."""

    adapter = OpenAIResponsesToAnthropicStreamAdapter()
    async for event in adapter.run(stream):
        yield event

convert__openai_chat_to_anthropic_messages__stream 

convert__openai_chat_to_anthropic_messages__stream(stream)

Translate OpenAI ChatCompletion streams into Anthropic message events.

Source code in ccproxy/llms/formatters/openai_to_anthropic/streams.py 
516
517
518
519
520
521
522
def convert__openai_chat_to_anthropic_messages__stream(
    stream: AsyncIterator[Any],
) -> AsyncGenerator[anthropic_models.MessageStreamEvent, None]:
    """Translate OpenAI ChatCompletion streams into Anthropic message events."""

    adapter = OpenAIChatToAnthropicStreamAdapter()
    return adapter.run(stream)