(event)
| 21 | future = loop.create_future() |
| 22 | |
| 23 | def on_event(event): |
| 24 | if isinstance(event.data, data_type) and (predicate is None or predicate(event.data)): |
| 25 | unsubscribe() |
| 26 | future.set_result(event) |
| 27 | |
| 28 | unsubscribe = session.on(on_event) |
| 29 | return future |
nothing calls this directly
no test coverage detected
searching dependent graphs…