Fixes Windows named pipe issue. Fixes #340.

This commit is contained in:
grossmj committed 2015-11-01 18:51:12 -07:00
1 parent 6edb41ded7
commit 32f9baf682
3 files changed
+26 -4

No files matched your search

+15
View File
@@ -108,3 +108,18 @@ def wait_for_file_creation(path, timeout=10):
yield from asyncio.sleep(0.5)
timeout -= 0.5
raise asyncio.TimeoutError()
@asyncio.coroutine
def wait_for_named_pipe_creation(pipe_path, timeout=10):
while timeout > 0:
try:
with open(pipe_path, "a+b"):
pass
except OSError:
yield from asyncio.sleep(0.5)
timeout -= 0.5
else:
return
raise asyncio.TimeoutError()