|
|
|
@@ -451,7 +451,7 @@ async def NoiseForwarder(mode, encrdrwrr, connvalid, priv_key, pub_key=None): |
|
|
|
while True: |
|
|
|
try: |
|
|
|
msg = await rdr.readexactly(2 + 16) |
|
|
|
except asyncio.streams.IncompleteReadError: |
|
|
|
except asyncio.IncompleteReadError: |
|
|
|
if rdr.at_eof(): |
|
|
|
return 'dec' |
|
|
|
|
|
|
|
@@ -902,7 +902,7 @@ class TestMain(unittest.TestCase): |
|
|
|
reader, writer = await connectsockstr(ptclientstr) |
|
|
|
|
|
|
|
# XXX - this might not be the best test. |
|
|
|
with self.assertRaises(asyncio.futures.TimeoutError): |
|
|
|
with self.assertRaises(asyncio.TimeoutError): |
|
|
|
# make sure that we don't get the conenction |
|
|
|
await asyncio.wait_for(ptsockevent.wait(), .5) |
|
|
|
|
|
|
|
|
