Close transport used to wait for user input, otherwise all further tests would fail on cleanup (FD leak detected). This in practice is only useful when using wait_on_fail decorator without --failfast option.
@@ -251,6 +251,7 @@ def wait_on_fail(func):
lambda: asyncio.StreamReaderProtocol(reader),
sys.stdin))
self.loop.run_until_complete(reader.readline())
+ transport.close()
raise
return wrapper