mirrors/cpython
1
0
Fork 0
mirror of https://github.com/python/cpython.git synced 2025-08-02 16:13:13 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 8

Merge 3.5 (asyncio)

Browse source
This commit is contained in:
Yury Selivanov 2016-05-13 15:59:48 -04:00
commit 8308db5cd5
1 changed files with 7 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

11
Lib/asyncio/streams.py
View file

@ -242,11 +242,14 @@ class StreamReaderProtocol(FlowControlMixin, protocols.Protocol):
self._loop.create_task(res) self._loop.create_task(res)
def connection_lost(self, exc): def connection_lost(self, exc):
if exc is None: if self._stream_reader is not None:
self._stream_reader.feed_eof() if exc is None:
else: self._stream_reader.feed_eof()
self._stream_reader.set_exception(exc) else:
self._stream_reader.set_exception(exc)
super().connection_lost(exc) super().connection_lost(exc)
self._stream_reader = None
self._stream_writer = None
def data_received(self, data): def data_received(self, data):
self._stream_reader.feed_data(data) self._stream_reader.feed_data(data)