asyncio: Fix _UnixWritePipeTransport, raise BrokenPipeError when the pipe is

closed, but only if there was pending write

diff --git a/Lib/asyncio/unix_events.py b/Lib/asyncio/unix_events.py
index ac764f8ad56c15580d345274c52546b90a9f5003..98fdddeec98c67745766c1dc050298df37625c50 100644 (file)
--- a/Lib/asyncio/unix_events.py
+++ b/Lib/asyncio/unix_events.py
@@ -283,7 +283,10 @@ class _UnixWritePipeTransport(selector_events._FlowControlMixin,
 
     def _read_ready(self):
         # Pipe was closed by peer.
-        self._close()
+        if self._buffer:
+            self._close(BrokenPipeError())
+        else:
+            self._close()
 
     def write(self, data):
         assert isinstance(data, (bytes, bytearray, memoryview)), repr(data)