(self, result,
timeout=None, on_interval=None, on_message=None,
**kwargs)
| 389 | p, timeout=timeout, on_interval=on_interval) |
| 390 | |
| 391 | def _wait_for_pending(self, result, |
| 392 | timeout=None, on_interval=None, on_message=None, |
| 393 | **kwargs): |
| 394 | self.on_wait_for_pending(result, timeout=timeout, **kwargs) |
| 395 | prev_on_m, self.on_message = self.on_message, on_message |
| 396 | try: |
| 397 | for _ in self.drain_events_until( |
| 398 | result.on_ready, timeout=timeout, |
| 399 | on_interval=on_interval): |
| 400 | yield |
| 401 | sleep(0) |
| 402 | except socket.timeout: |
| 403 | raise TimeoutError('The operation timed out.') |
| 404 | finally: |
| 405 | self.on_message = prev_on_m |
| 406 | |
| 407 | def on_wait_for_pending(self, result, timeout=None, **kwargs): |
| 408 | pass |
nothing calls this directly
no test coverage detected