Refs #33173, Refs #33755 -- Fixed ResourceWarning from unclosed files in ASGI tests.

carltongibson · carltongibson · commit f476c8847a0b · 2022-08-04T10:00:36.000+02:00
diff --git a/tests/asgi/tests.py b/tests/asgi/tests.py
@@ -55,6 +55,8 @@ async def test_get_asgi_application(self):
         response_body = await communicator.receive_output()
         self.assertEqual(response_body["type"], "http.response.body")
         self.assertEqual(response_body["body"], b"Hello World!")
+        # Allow response.close() to finish.
+        await communicator.wait()
 
     async def test_file_response(self):
         """
@@ -162,6 +164,8 @@ async def test_headers(self):
         response_body = await communicator.receive_output()
         self.assertEqual(response_body["type"], "http.response.body")
         self.assertEqual(response_body["body"], b"From Scotland,Wales")
+        # Allow response.close() to finish
+        await communicator.wait()
 
     async def test_post_body(self):
         application = get_asgi_application()
@@ -190,6 +194,8 @@ async def test_untouched_request_body_gets_closed(self):
         response_body = await communicator.receive_output()
         self.assertEqual(response_body["type"], "http.response.body")
         self.assertEqual(response_body["body"], b"")
+        # Allow response.close() to finish
+        await communicator.wait()
 
     async def test_get_query_string(self):
         application = get_asgi_application()
@@ -207,6 +213,8 @@ async def test_get_query_string(self):
                 response_body = await communicator.receive_output()
                 self.assertEqual(response_body["type"], "http.response.body")
                 self.assertEqual(response_body["body"], b"Hello Andrew!")
+                # Allow response.close() to finish
+                await communicator.wait()
 
     async def test_disconnect(self):
         application = get_asgi_application()
