Skip to content

Commit 91c8678

Browse files
committed
pythongh-90467: StreamReaderProtocol - add strong reference to created task
1 parent b462f14 commit 91c8678

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

Lib/asyncio/streams.py

+3-1
Original file line numberDiff line numberDiff line change
@@ -205,6 +205,7 @@ def __init__(self, stream_reader, client_connected_cb=None, loop=None):
205205
self._strong_reader = stream_reader
206206
self._reject_connection = False
207207
self._stream_writer = None
208+
self._task = None
208209
self._transport = None
209210
self._client_connected_cb = client_connected_cb
210211
self._over_ssl = False
@@ -247,7 +248,7 @@ def connection_made(self, transport):
247248
res = self._client_connected_cb(reader,
248249
self._stream_writer)
249250
if coroutines.iscoroutine(res):
250-
self._loop.create_task(res)
251+
self._task = self._loop.create_task(res)
251252
self._strong_reader = None
252253

253254
def connection_lost(self, exc):
@@ -265,6 +266,7 @@ def connection_lost(self, exc):
265266
super().connection_lost(exc)
266267
self._stream_reader_wr = None
267268
self._stream_writer = None
269+
self._task = None
268270
self._transport = None
269271

270272
def data_received(self, data):

0 commit comments

Comments
 (0)