(event)
| 192 | future = loop.create_future() |
| 193 | |
| 194 | def on_event(event): |
| 195 | if not future.done() and predicate(event): |
| 196 | future.set_result(event) |
| 197 | |
| 198 | unsubscribe = session.on(on_event) |
| 199 |
nothing calls this directly
no test coverage detected
searching dependent graphs…