asyncio: Pass through pause/resume from subprocess pipe proto to subprocess proto. Also kill dummy eof_received().

This commit is contained in:
Guido van Rossum 2014-01-29 14:28:15 -08:00
parent 4d62d0b353
commit 1e9a446ebe
1 changed files with 5 additions and 2 deletions

View File

@ -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,