Update examples

examples/demo.py

@@ -1,5 +1,6 @@
 import asyncio
-from aiostream import stream, pipe
+
+from aiostream import pipe, stream
 
 
 async def main():
@@ -33,6 +34,4 @@ async def main():
 
 
 # Run main coroutine
-loop = asyncio.get_event_loop()
-loop.run_until_complete(main())
-loop.close()
+asyncio.run(main())

examples/extra.py

@@ -37,6 +37,4 @@ async def main():
 
 
 # Run main coroutine
-loop = asyncio.get_event_loop()
-loop.run_until_complete(main())
-loop.close()
+asyncio.run(main())

examples/norm_server.py

@@ -15,7 +15,8 @@
 """
 
 import asyncio
-from aiostream import stream, pipe
+
+from aiostream import pipe, stream
 
 # Constants
 
@@ -85,26 +86,18 @@ def square_root(x):
 # Main function
 
 
-def run_server(bind="127.0.0.1", port=8888):
+async def main(bind="127.0.0.1", port=8888):
     # Start the server
-    loop = asyncio.get_event_loop()
-    coro = asyncio.start_server(euclidean_norm_handler, bind, port)
-    server = loop.run_until_complete(coro)
+    server = await asyncio.start_server(euclidean_norm_handler, bind, port)
 
     # Serve requests until Ctrl+C is pressed
     print("Serving on {}".format(server.sockets[0].getsockname()))
-    try:
-        loop.run_forever()
-    except KeyboardInterrupt:
-        pass
 
-    # Close the server
-    server.close()
-    loop.run_until_complete(server.wait_closed())
-    loop.close()
+    async with server:
+        await server.serve_forever()
 
 
 # Main execution
 
 if __name__ == "__main__":
-    run_server()
+    asyncio.run(main())

examples/preserve.py

@@ -1,5 +1,6 @@
 import asyncio
-from aiostream import stream, operator
+
+from aiostream import operator, stream
 
 
 async def main():
@@ -26,6 +27,4 @@ async def agen():
 
 
 # Run main coroutine
-loop = asyncio.get_event_loop()
-loop.run_until_complete(main())
-loop.close()
+asyncio.run(main())

examples/simple.py

@@ -1,5 +1,6 @@
 import asyncio
-from aiostream import stream, pipe
+
+from aiostream import pipe, stream
 
 
 async def main():
@@ -16,6 +17,4 @@ async def main():
 
 
 # Run main coroutine
-loop = asyncio.get_event_loop()
-loop.run_until_complete(main())
-loop.close()
+asyncio.run(main())