| 123456789101112131415161718192021222324252627282930 |
- from __future__ import annotations
- import sys
- __all__ = ["TimeoutError", "aiter", "anext", "asyncio_timeout", "asyncio_timeout_at"]
- if sys.version_info[:2] >= (3, 11):
- TimeoutError = TimeoutError
- aiter = aiter
- anext = anext
- from asyncio import (
- timeout as asyncio_timeout, # noqa: F401
- timeout_at as asyncio_timeout_at, # noqa: F401
- )
- else: # Python < 3.11
- from asyncio import TimeoutError
- def aiter(async_iterable):
- return type(async_iterable).__aiter__(async_iterable)
- async def anext(async_iterator):
- return await type(async_iterator).__anext__(async_iterator)
- from .async_timeout import (
- timeout as asyncio_timeout, # noqa: F401
- timeout_at as asyncio_timeout_at, # noqa: F401
- )
|
