(self)
| 384 | return self |
| 385 | |
| 386 | def __next__(self): |
| 387 | if self._exhausted: |
| 388 | raise StopIteration |
| 389 | |
| 390 | if not self._started: |
| 391 | self._start_request() |
| 392 | self._started = True |
| 393 | |
| 394 | return self._read_next_chunk() |
| 395 | |
| 396 | def _start_request(self): |
| 397 | """Send the initial request to the arbiter.""" |
nothing calls this directly
no test coverage detected