(
self,
emitter: EventEmitter,
event: str,
predicate: Callable = None,
)
| 111 | self._wait_for_event_info_after(self._wait_id, exception) |
| 112 | |
| 113 | def wait_for_event( |
| 114 | self, |
| 115 | emitter: EventEmitter, |
| 116 | event: str, |
| 117 | predicate: Callable = None, |
| 118 | ) -> None: |
| 119 | def listener(event_data: Any = None) -> None: |
| 120 | self._evaluate_predicate( |
| 121 | predicate, event_data, lambda: self._fulfill(event_data) |
| 122 | ) |
| 123 | |
| 124 | emitter.on(event, listener) |
| 125 | self._registered_listeners.append((emitter, event, listener)) |
| 126 | |
| 127 | def _evaluate_predicate( |
| 128 | self, |
no test coverage detected