(self, failure: Failure)
| 251 | self._call_anext() |
| 252 | |
| 253 | def _errback(self, failure: Failure) -> None: |
| 254 | # This gets called on any exceptions in aiterator.__anext__(). |
| 255 | # It handles StopAsyncIteration by stopping the iteration and reraises all others. |
| 256 | self.anext_deferred = None |
| 257 | failure.trap(StopAsyncIteration) |
| 258 | self.finished = True |
| 259 | for d in self.waiting_deferreds: |
| 260 | d.callback(None) |
| 261 | |
| 262 | def _call_anext(self) -> None: |
| 263 | # This starts waiting for the next result from aiterator. |