pass through pause/resume from subprocess pipe proto to subprocess proto.

gvanrossum · gvanrossum · commit 30986ed26d9e · 2014-01-28T08:34:19.000-08:00
diff --git a/asyncio/base_subprocess.py b/asyncio/base_subprocess.py
@@ -150,8 +150,11 @@ def connection_lost(self, exc):
         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,
