traverseda
/
cpython
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Merge 3.4 (asyncio)

This commit is contained in:
Victor Stinner 2015-01-15 22:53:21 +01:00
parent 0caf060056 f716d8b7a5
commit 5f9fd1dd79
1 changed files with 12 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
Lib/test/test_asyncio/test_subprocess.py
View File

@ -179,6 +179,18 @@ class SubprocessMixin:
'sys.stdout.write("x" * %s)' % size, 'sys.stdout.write("x" * %s)' % size,
'sys.stdout.flush()', 'sys.stdout.flush()',
)) ))
connect_read_pipe = self.loop.connect_read_pipe
@asyncio.coroutine
def connect_read_pipe_mock(*args, **kw):
transport, protocol = yield from connect_read_pipe(*args, **kw)
transport.pause_reading = mock.Mock()
transport.resume_reading = mock.Mock()
return (transport, protocol)
self.loop.connect_read_pipe = connect_read_pipe_mock
proc = yield from asyncio.create_subprocess_exec( proc = yield from asyncio.create_subprocess_exec(
sys.executable, '-c', code, sys.executable, '-c', code,
stdin=asyncio.subprocess.PIPE, stdin=asyncio.subprocess.PIPE,
@ -186,8 +198,6 @@ class SubprocessMixin:
limit=limit, limit=limit,
loop=self.loop) loop=self.loop)
stdout_transport = proc._transport.get_pipe_transport(1) stdout_transport = proc._transport.get_pipe_transport(1)
stdout_transport.pause_reading = mock.Mock()
stdout_transport.resume_reading = mock.Mock()
stdout, stderr = yield from proc.communicate() stdout, stderr = yield from proc.communicate()