import re
import codecs
import struct
-from typing import TYPE_CHECKING, AsyncGenerator, Generator
+from typing import TYPE_CHECKING, AsyncIterator, Iterator
from typing import Any, Dict, List, Match, Optional, Sequence, Type, Union
from types import TracebackType
else:
self.finish(str(exc_val))
- def __iter__(self) -> Generator[bytes, None, None]:
+ def __iter__(self) -> Iterator[bytes]:
while 1:
data = self.read()
if data is None:
else:
await self.finish(str(exc_val))
- async def __aiter__(self) -> AsyncGenerator[bytes, None]:
+ async def __aiter__(self) -> AsyncIterator[bytes]:
while 1:
data = await self.read()
if data is None:
# Copyright (C) 2020 The Psycopg Team
import re
-from typing import Dict, Generator, Optional, Union
+from typing import Dict, Iterator, Optional, Union
INVALID_OID = 0
if info.alt_name not in self._by_name:
self._by_name[info.alt_name] = info
- def __iter__(self) -> Generator[TypeInfo, None, None]:
+ def __iter__(self) -> Iterator[TypeInfo]:
seen = set()
for t in self._by_oid.values():
if t.oid not in seen:
import re
import struct
-from typing import Any, Generator, List, Optional, Type
+from typing import Any, Iterator, List, Optional, Type
from .. import errors as e
from ..oids import builtins
_struct_dim.unpack_from(data, i)[0] for i in list(range(12, p, 8))
]
- def consume(p: int) -> Generator[Any, None, None]:
+ def consume(p: int) -> Iterator[Any]:
while 1:
size = _struct_len.unpack_from(data, p)[0]
p += 4
import re
import struct
from collections import namedtuple
-from typing import Any, Callable, Generator, Sequence, Tuple, Type
+from typing import Any, Callable, Iterator, Sequence, Tuple, Type
from typing import Optional, TYPE_CHECKING
from .. import pq
for token in self._parse_record(data)
)
- def _parse_record(
- self, data: bytes
- ) -> Generator[Optional[bytes], None, None]:
+ def _parse_record(self, data: bytes) -> Iterator[Optional[bytes]]:
if data == b"()":
return
)
)
- def _walk_record(
- self, data: bytes
- ) -> Generator[Tuple[int, int, int], None, None]:
+ def _walk_record(self, data: bytes) -> Iterator[Tuple[int, int, int]]:
"""
Yield a sequence of (oid, offset, length) for the content of the record
"""