Function _parse_openai_events

tests/test_anthropic_compat.py:581–594

(raw_events: list[bytes])

def _parse_openai_events(raw_events: list[bytes]) -> tuple[list[dict], bool]:
    results: list[dict] = []
    done = False
    for raw in raw_events:
        text = raw.decode()
        for line in text.strip().split("\n"):
            if not line.startswith("data: "):
                continue
            payload = line[6:]
            if payload == "[DONE]":
                done = True
                continue
            results.append(json.loads(payload))
    return results, done


class TestStreamConverter: