(coro: Any)
| 141 | if inspect.iscoroutine(result): |
| 142 | |
| 143 | async def _await_predicate(coro: Any) -> None: |
| 144 | try: |
| 145 | matched = await coro |
| 146 | except Exception as e: |
| 147 | self._reject(e) |
| 148 | return |
| 149 | if matched and not self._result.done(): |
| 150 | on_match() |
| 151 | |
| 152 | self._pending_tasks.append(self._loop.create_task(_await_predicate(result))) |
| 153 | return |