(self, result,
timeout=None, on_interval=None, on_message=None,
**kwargs)
| 300 | return result.maybe_throw(callback=callback, propagate=propagate) |
| 301 | |
| 302 | def _wait_for_pending(self, result, |
| 303 | timeout=None, on_interval=None, on_message=None, |
| 304 | **kwargs): |
| 305 | return self.result_consumer._wait_for_pending( |
| 306 | result, timeout=timeout, |
| 307 | on_interval=on_interval, on_message=on_message, |
| 308 | **kwargs |
| 309 | ) |
| 310 | |
| 311 | @property |
| 312 | def is_async(self): |
no outgoing calls
no test coverage detected