test fix after last threaded-runner change
@@ -47,9 +47,9 @@ def test_can_await_connection_observer_to_complete(observer_and_awaited_data,
connection_observer_future,
timeout=1.0)
assert not connection_observer_future.running()
- assert connection_observer_future.done()
assert conn_observer.done()
- assert connection_observer_future.result() is not None
+ assert connection_observer_future.done()
+ assert connection_observer_future.result() is None
finally: # test cleanup
ext_io.join()
connection_observer_future.cancel()
