diff options
| author | Guido van Rossum <guido@python.org> | 2014-01-29 22:28:15 (GMT) |
|---|---|---|
| committer | Guido van Rossum <guido@python.org> | 2014-01-29 22:28:15 (GMT) |
| commit | 1e9a446ebeced921a5da3d9647e96cdd767504a9 (patch) | |
| tree | 631a719c015290b16239be876a7050909e354512 | |
| parent | 4d62d0b353dbc02a303e797673a41879a255c1fc (diff) | |
| download | cpython-1e9a446ebeced921a5da3d9647e96cdd767504a9.zip cpython-1e9a446ebeced921a5da3d9647e96cdd767504a9.tar.gz cpython-1e9a446ebeced921a5da3d9647e96cdd767504a9.tar.bz2 | |
asyncio: Pass through pause/resume from subprocess pipe proto to subprocess proto. Also kill dummy eof_received().
| -rw-r--r-- | Lib/asyncio/base_subprocess.py | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/Lib/asyncio/base_subprocess.py b/Lib/asyncio/base_subprocess.py index cc4f8cb..b7cdbce 100644 --- a/Lib/asyncio/base_subprocess.py +++ b/Lib/asyncio/base_subprocess.py @@ -150,8 +150,11 @@ class WriteSubprocessPipeProto(protocols.BaseProtocol): self.disconnected = True self.proc._pipe_connection_lost(self.fd, exc) - def eof_received(self): - pass + def pause_writing(self): + self.proc._protocol.pause_writing() + + def resume_writing(self): + self.proc._protocol.resume_writing() class ReadSubprocessPipeProto(WriteSubprocessPipeProto, |