python
diff --git a/‎Lib/asyncio/base_events.py
Copy file name to clipboardExpand all lines: Lib/asyncio/base_events.py
+1-1Lines changed: 1 addition & 1 deletion b/‎Lib/asyncio/base_events.py
Copy file name to clipboardExpand all lines: Lib/asyncio/base_events.py
+1-1Lines changed: 1 addition & 1 deletion
diff --git a/‎Lib/test/test_asyncio/test_base_events.py
Copy file name to clipboardExpand all lines: Lib/test/test_asyncio/test_base_events.py
+1-1Lines changed: 1 addition & 1 deletion b/‎Lib/test/test_asyncio/test_base_events.py
Copy file name to clipboardExpand all lines: Lib/test/test_asyncio/test_base_events.py
+1-1Lines changed: 1 addition & 1 deletion
diff --git a/‎Lib/test/test_asyncio/test_server.py
Copy file name to clipboardExpand all lines: Lib/test/test_asyncio/test_server.py
+27Lines changed: 27 additions & 0 deletions b/‎Lib/test/test_asyncio/test_server.py
Copy file name to clipboardExpand all lines: Lib/test/test_asyncio/test_server.py
+27Lines changed: 27 additions & 0 deletions
diff --git a/‎Misc/NEWS.d/next/Library/2022-11-22-19-31-26.gh-issue-79033.MW6kHq.rst
Copy file name to clipboard
+1Lines changed: 1 addition & 0 deletions b/‎Misc/NEWS.d/next/Library/2022-11-22-19-31-26.gh-issue-79033.MW6kHq.rst
Copy file name to clipboard
+1Lines changed: 1 addition & 0 deletions
@@ -377,7 +377,7 @@ async def serve_forever(self):
             self._serving_forever_fut = None
 
     async def wait_closed(self):
-        if self._sockets is None or self._waiters is None:
+        if self._waiters is None or self._active_count == 0:
             return
         waiter = self._loop.create_future()
         self._waiters.append(waiter)
 
@@ -2052,11 +2052,11 @@ def prepare(self):
 
         def cleanup():
             server.close()
-            self.run_loop(server.wait_closed())
             sock.close()
             if proto.transport is not None:
                 proto.transport.close()
                 self.run_loop(proto.wait_closed())
+            self.run_loop(server.wait_closed())
 
         self.addCleanup(cleanup)
 
 
@@ -120,6 +120,33 @@ async def main(srv):
                 self.loop.run_until_complete(srv.serve_forever())
 
 
+class TestServer2(unittest.IsolatedAsyncioTestCase):
+
+    async def test_wait_closed(self):
+        async def serve(*args):
+            pass
+
+        srv = await asyncio.start_server(serve, socket_helper.HOSTv4, 0)
+
+        # active count = 0
+        task1 = asyncio.create_task(srv.wait_closed())
+        await asyncio.sleep(0)
+        self.assertTrue(task1.done())
+
+        # active count != 0
+        srv._attach()
+        task2 = asyncio.create_task(srv.wait_closed())
+        await asyncio.sleep(0)
+        self.assertFalse(task2.done())
+
+        srv.close()
+        await asyncio.sleep(0)
+        self.assertFalse(task2.done())
+
+        srv._detach()
+        await task2
+
+
 @unittest.skipUnless(hasattr(asyncio, 'ProactorEventLoop'), 'Windows only')
 class ProactorStartServerTests(BaseStartServer, unittest.TestCase):
 
 
@@ -0,0 +1 @@
+Fix :func:`asyncio.Server.wait_closed` to actually do what the docs promise -- wait for all existing connections to complete, after closing the server.
Original file line number	Diff line number	Diff line change
`@@ -0,0 +1 @@`
	`1`	+Fix :func:`asyncio.Server.wait_closed` to actually do what the docs promise -- wait for all existing connections to complete, after closing the server.