.venv/lib/python3.12/site-packages/openai/_utils/_streams.py


1
2
3
4
5
6
7
8
9
10
11
12

from typing import Any
from typing_extensions import Iterator, AsyncIterator


def consume_sync_iterator(iterator: Iterator[Any]) -> None:
    for _ in iterator:
        ...


async def consume_async_iterator(iterator: AsyncIterator[Any]) -> None:
    async for _ in iterator:
        ...