Simplify pattern for running servers forever.

Author: aaugustin

README.rst

@@ -54,8 +54,8 @@ Here's an echo server with the ``asyncio`` API:
             await websocket.send(message)
 
     async def main():
-        async with serve(echo, "localhost", 8765):
-            await asyncio.get_running_loop().create_future()  # run forever
+        async with serve(echo, "localhost", 8765) as server:
+            await server.serve_forever()
 
     asyncio.run(main())
 

docs/intro/tutorial1.rst

@@ -194,8 +194,8 @@ Create an ``app.py`` file next to ``connect4.py`` with this content:
 
 
     async def main():
-        async with serve(handler, "", 8001):
-            await asyncio.get_running_loop().create_future()  # run forever
+        async with serve(handler, "", 8001) as server:
+            await server.serve_forever()
 
 
     if __name__ == "__main__":

example/django/authentication.py

@@ -22,8 +22,8 @@ async def handler(websocket):
 
 
 async def main():
-    async with serve(handler, "localhost", 8888):
-        await asyncio.get_running_loop().create_future()  # run forever
+    async with serve(handler, "localhost", 8888) as server:
+        await server.serve_forever()
 
 
 if __name__ == "__main__":

example/faq/health_check_server.py

@@ -13,7 +13,7 @@ async def echo(websocket):
         await websocket.send(message)
 
 async def main():
-    async with serve(echo, "localhost", 8765, process_request=health_check):
-        await asyncio.get_running_loop().create_future()  # run forever
+    async with serve(echo, "localhost", 8765, process_request=health_check) as server:
+        await server.serve_forever()
 
 asyncio.run(main())

example/quickstart/counter.py

@@ -42,8 +42,8 @@ async def counter(websocket):
         broadcast(USERS, users_event())
 
 async def main():
-    async with serve(counter, "localhost", 6789):
-        await asyncio.get_running_loop().create_future()  # run forever
+    async with serve(counter, "localhost", 6789) as server:
+        await server.serve_forever()
 
 if __name__ == "__main__":
     asyncio.run(main())

example/quickstart/server.py

@@ -14,8 +14,8 @@ async def hello(websocket):
     print(f">>> {greeting}")
 
 async def main():
-    async with serve(hello, "localhost", 8765):
-        await asyncio.get_running_loop().create_future()  # run forever
+    async with serve(hello, "localhost", 8765) as server:
+        await server.serve_forever()
 
 if __name__ == "__main__":
     asyncio.run(main())

example/quickstart/server_secure.py

@@ -20,8 +20,8 @@ async def hello(websocket):
 ssl_context.load_cert_chain(localhost_pem)
 
 async def main():
-    async with serve(hello, "localhost", 8765, ssl=ssl_context):
-        await asyncio.get_running_loop().create_future()  # run forever
+    async with serve(hello, "localhost", 8765, ssl=ssl_context) as server:
+        await server.serve_forever()
 
 if __name__ == "__main__":
     asyncio.run(main())

example/quickstart/show_time.py

@@ -13,8 +13,8 @@ async def show_time(websocket):
         await asyncio.sleep(random.random() * 2 + 1)
 
 async def main():
-    async with serve(show_time, "localhost", 5678):
-        await asyncio.get_running_loop().create_future()  # run forever
+    async with serve(show_time, "localhost", 5678) as server:
+        await server.serve_forever()
 
 if __name__ == "__main__":
     asyncio.run(main())

example/routing.py

@@ -146,8 +146,8 @@ def format_timedelta(delta):
 
 
 async def main():
-    async with route(url_map, "localhost", 8888):
-        await asyncio.get_running_loop().create_future()  # run forever
+    async with route(url_map, "localhost", 8888) as server:
+        await server.serve_forever()
 
 
 if __name__ == "__main__":

example/tutorial/step1/app.py

@@ -57,8 +57,8 @@ async def handler(websocket):
 
 
 async def main():
-    async with serve(handler, "", 8001):
-        await asyncio.get_running_loop().create_future()  # run forever
+    async with serve(handler, "", 8001) as server:
+        await server.serve_forever()
 
 
 if __name__ == "__main__":

example/tutorial/step2/app.py

@@ -182,8 +182,8 @@ async def handler(websocket):
 
 
 async def main():
-    async with serve(handler, "", 8001):
-        await asyncio.get_running_loop().create_future()  # run forever
+    async with serve(handler, "", 8001) as server:
+        await server.serve_forever()
 
 
 if __name__ == "__main__":