diff options
| author | Miss Islington (bot) <31488909+miss-islington@users.noreply.github.com> | 2019-12-07 11:39:57 (GMT) |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2019-12-07 11:39:57 (GMT) |
| commit | 7fde4f446a3dcfed780a38fbfcd7c0b4d9d73b93 (patch) | |
| tree | fab43c7b8e7d3e52640784169742288c49302aa8 /Lib/asyncio | |
| parent | 836cf31a3cf468ed9598a220b8e194b366287bfe (diff) | |
| download | cpython-7fde4f446a3dcfed780a38fbfcd7c0b4d9d73b93.zip cpython-7fde4f446a3dcfed780a38fbfcd7c0b4d9d73b93.tar.gz cpython-7fde4f446a3dcfed780a38fbfcd7c0b4d9d73b93.tar.bz2 | |
bpo-38529: Fix asyncio stream warning (GH-17474)
(cherry picked from commit 7ddcd0caa4c2e6b43265df144f59c5aa508a94f2)
Co-authored-by: Andrew Svetlov <andrew.svetlov@gmail.com>
Diffstat (limited to 'Lib/asyncio')
| -rw-r--r-- | Lib/asyncio/streams.py | 19 |
1 files changed, 1 insertions, 18 deletions
diff --git a/Lib/asyncio/streams.py b/Lib/asyncio/streams.py index 795530e..3c80bb8 100644 --- a/Lib/asyncio/streams.py +++ b/Lib/asyncio/streams.py @@ -214,8 +214,7 @@ class StreamReaderProtocol(FlowControlMixin, protocols.Protocol): def __init__(self, stream_reader, client_connected_cb=None, loop=None): super().__init__(loop=loop) if stream_reader is not None: - self._stream_reader_wr = weakref.ref(stream_reader, - self._on_reader_gc) + self._stream_reader_wr = weakref.ref(stream_reader) self._source_traceback = stream_reader._source_traceback else: self._stream_reader_wr = None @@ -231,22 +230,6 @@ class StreamReaderProtocol(FlowControlMixin, protocols.Protocol): self._over_ssl = False self._closed = self._loop.create_future() - def _on_reader_gc(self, wr): - transport = self._transport - if transport is not None: - # connection_made was called - context = { - 'message': ('An open stream object is being garbage ' - 'collected; call "stream.close()" explicitly.') - } - if self._source_traceback: - context['source_traceback'] = self._source_traceback - self._loop.call_exception_handler(context) - transport.abort() - else: - self._reject_connection = True - self._stream_reader_wr = None - @property def _stream_reader(self): if self._stream_reader_wr is None: |