From 5e86cdf725d4795c363e743116c95d89f988b918 Mon Sep 17 00:00:00 2001
From: Kumar Aditya <59607654+kumaraditya303@users.noreply.github.com>
Date: Sat, 5 Aug 2023 04:55:30 +0000
Subject: [PATCH 1/4] raise ResourceWarning when StreamWriter is not closed

---
 Lib/asyncio/streams.py | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/Lib/asyncio/streams.py b/Lib/asyncio/streams.py
index bf15f517e50dce..0aa9abd7c34215 100644
--- a/Lib/asyncio/streams.py
+++ b/Lib/asyncio/streams.py
@@ -5,6 +5,7 @@
 import collections
 import socket
 import sys
+import warnings
 import weakref
 
 if hasattr(socket, 'AF_UNIX'):
@@ -392,6 +393,11 @@ async def start_tls(self, sslcontext, *,
         self._transport = new_transport
         protocol._replace_writer(self)
 
+    def __del__(self, warnings=warnings):
+        if not self._transport.is_closing():
+            self.close()
+            warnings.warn(f"unclosed {self!r}", ResourceWarning)
+
 
 class StreamReader:
 
@@ -746,3 +752,4 @@ async def __anext__(self):
         if val == b'':
             raise StopAsyncIteration
         return val
+

From 066d128ed770f68e04e53170e3e31f81582eed95 Mon Sep 17 00:00:00 2001
From: Kumar Aditya <59607654+kumaraditya303@users.noreply.github.com>
Date: Sat, 5 Aug 2023 05:01:19 +0000
Subject: [PATCH 2/4] fix lint

---
 Lib/asyncio/streams.py | 1 -
 1 file changed, 1 deletion(-)

diff --git a/Lib/asyncio/streams.py b/Lib/asyncio/streams.py
index 0aa9abd7c34215..b7ad365709b19e 100644
--- a/Lib/asyncio/streams.py
+++ b/Lib/asyncio/streams.py
@@ -752,4 +752,3 @@ async def __anext__(self):
         if val == b'':
             raise StopAsyncIteration
         return val
-

From f11cef0dbc052d52aed808fd6c9afb1415a9a455 Mon Sep 17 00:00:00 2001
From: Kumar Aditya <59607654+kumaraditya303@users.noreply.github.com>
Date: Sat, 5 Aug 2023 05:08:10 +0000
Subject: [PATCH 3/4] add test

---
 Lib/test/test_asyncio/test_streams.py | 23 +++++++++++++++++++++++
 1 file changed, 23 insertions(+)

diff --git a/Lib/test/test_asyncio/test_streams.py b/Lib/test/test_asyncio/test_streams.py
index 7f9dc621808358..9c92e75886c593 100644
--- a/Lib/test/test_asyncio/test_streams.py
+++ b/Lib/test/test_asyncio/test_streams.py
@@ -1074,6 +1074,29 @@ def test_eof_feed_when_closing_writer(self):
 
         self.assertEqual(messages, [])
 
+    def test_unclosed_resource_warnings(self):
+        async def inner(httpd):
+            rd, wr = await asyncio.open_connection(*httpd.address)
+
+            wr.write(b'GET / HTTP/1.0\r\n\r\n')
+            data = await rd.readline()
+            self.assertEqual(data, b'HTTP/1.0 200 OK\r\n')
+            data = await rd.read()
+            self.assertTrue(data.endswith(b'\r\n\r\nTest message'))
+            with self.assertWarns(ResourceWarning):
+                del wr
+                gc.collect()
+
+
+        messages = []
+        self.loop.set_exception_handler(lambda loop, ctx: messages.append(ctx))
+
+        with test_utils.run_test_server() as httpd:
+            self.loop.run_until_complete(inner(httpd))
+
+        self.assertEqual(messages, [])
+
+
 
 if __name__ == '__main__':
     unittest.main()

From 1e9f9021e6e9c8dd2eedf1cdcfa971ee452c613c Mon Sep 17 00:00:00 2001
From: "blurb-it[bot]" <43283697+blurb-it[bot]@users.noreply.github.com>
Date: Sat, 5 Aug 2023 05:10:47 +0000
Subject: [PATCH 4/4] =?UTF-8?q?=F0=9F=93=9C=F0=9F=A4=96=20Added=20by=20blu?=
 =?UTF-8?q?rb=5Fit.?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../next/Library/2023-08-05-05-10-41.gh-issue-106684.P9zRXb.rst  | 1 +
 1 file changed, 1 insertion(+)
 create mode 100644 Misc/NEWS.d/next/Library/2023-08-05-05-10-41.gh-issue-106684.P9zRXb.rst

diff --git a/Misc/NEWS.d/next/Library/2023-08-05-05-10-41.gh-issue-106684.P9zRXb.rst b/Misc/NEWS.d/next/Library/2023-08-05-05-10-41.gh-issue-106684.P9zRXb.rst
new file mode 100644
index 00000000000000..02c52d714e9df7
--- /dev/null
+++ b/Misc/NEWS.d/next/Library/2023-08-05-05-10-41.gh-issue-106684.P9zRXb.rst
@@ -0,0 +1 @@
+Raise :exc:`ResourceWarning` when :class:`asyncio.StreamWriter` is not closed leading to memory leaks. Patch by Kumar Aditya.