MCPcopy
hub / github.com/psycopg/psycopg / __anext__

Method __anext__

psycopg/psycopg/cursor_async.py:291–298  ·  view source on GitHub ↗
(self)

Source from the content-addressed store, hash-verified

289 return self
290
291 async def __anext__(self) -> Row:
292 await self._fetch_pipeline()
293 res = self._check_result_for_fetch()
294 if self._pos < res.ntuples:
295 record = self._tx.load_row(self._pos, self._make_row)
296 self._pos += 1
297 return record
298 raise StopAsyncIteration("no more records to return")
299
300 async def scroll(self, value: int, mode: str = "relative") -> None:
301 """

Callers

nothing calls this directly

Calls 3

_fetch_pipelineMethod · 0.95
load_rowMethod · 0.45

Tested by

no test coverage detected