(self, batches: list[list[str]], per_batch_delay: float = 0.0)
| 35 | """ |
| 36 | |
| 37 | def __init__(self, batches: list[list[str]], per_batch_delay: float = 0.0) -> None: |
| 38 | self._batches = list(batches) |
| 39 | self._per_batch_delay = per_batch_delay |
| 40 | |
| 41 | async def read_lines(self, timeout: float) -> AsyncIterator[str]: # noqa: ARG002 |
| 42 | if not self._batches: |