Jan 14, 2015 · Jan 14, 2015 · Jan 14, 2015 · Jan 14, 2015 · Jan 14, 2015 · Jan 14, 2015
diff --git a/tests/test_subprocess.py b/tests/test_subprocess.py
                'sys.stdout.write("x" * %s)' % size,
                '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(
                                         sys.executable, '-c', code,
                                         stdin=asyncio.subprocess.PIPE,
                                         stdout=asyncio.subprocess.PIPE,
                                         limit=limit,
                                         loop=self.loop)
            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()
Original file line number	Diff line number	Diff line change
Expand Up		@@ -179,15 +179,25 @@ def test_pause_reading():
		'sys.stdout.write("x" * %s)' % size,
		'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(
		sys.executable, '-c', code,
		stdin=asyncio.subprocess.PIPE,
		stdout=asyncio.subprocess.PIPE,
		limit=limit,
		loop=self.loop)
		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()

Expand Down