diff --git a/README.md b/README.md index 987baaa..42a1d71 100644 --- a/README.md +++ b/README.md @@ -78,8 +78,6 @@ from dbus_fast.aio import MessageBus import asyncio -loop = asyncio.get_running_loop() - async def main(): bus = await MessageBus().connect() @@ -106,9 +104,9 @@ async def main(): properties.on_properties_changed(on_properties_changed) - await loop.create_future() + await asyncio.Event().wait() -loop.run_until_complete(main()) +asyncio.run(main()) ``` ## The Service Interface @@ -159,9 +157,9 @@ async def main(): # now that we are ready to handle requests, we can request name from D-Bus await bus.request_name('test.name') # wait indefinitely - await asyncio.get_running_loop().create_future() + await asyncio.Event().wait() -asyncio.get_running_loop().run_until_complete(main()) +asyncio.run(main()) ``` ## The Low-Level Interface @@ -177,8 +175,6 @@ from dbus_fast.aio import MessageBus import asyncio import json -loop = asyncio.get_running_loop() - async def main(): bus = await MessageBus().connect() @@ -195,7 +191,7 @@ async def main(): print(json.dumps(reply.body[0], indent=2)) -loop.run_until_complete(main()) +asyncio.run(main()) ``` ## Projects that use python-dbus-fast diff --git a/docs/source/high-level-service/index.rst b/docs/source/high-level-service/index.rst index e8f86f4..e705c0a 100644 --- a/docs/source/high-level-service/index.rst +++ b/docs/source/high-level-service/index.rst @@ -90,4 +90,4 @@ If any file descriptors are sent or received (DBus type ``h``), the variable ref await bus.wait_for_disconnect() - asyncio.get_running_loop().run_until_complete(main()) + asyncio.run(main()) diff --git a/examples/aio-list-names.py b/examples/aio-list-names.py index 41f9af4..ae4d364 100755 --- a/examples/aio-list-names.py +++ b/examples/aio-list-names.py @@ -10,8 +10,6 @@ import json from dbus_fast import Message, MessageType from dbus_fast.aio import MessageBus -loop = asyncio.get_running_loop() - async def main(): bus = await MessageBus().connect() @@ -31,4 +29,4 @@ async def main(): print(json.dumps(reply.body[0], indent=2)) -loop.run_until_complete(main()) +asyncio.run(main()) diff --git a/examples/aio-tcp-notification.py b/examples/aio-tcp-notification.py index 2687229..6c09ebf 100755 --- a/examples/aio-tcp-notification.py +++ b/examples/aio-tcp-notification.py @@ -17,8 +17,6 @@ import asyncio from dbus_fast.aio import MessageBus -loop = asyncio.get_running_loop() - async def main(): bus = await MessageBus(bus_address="tcp:host=127.0.0.1,port=55556").connect() @@ -34,4 +32,4 @@ async def main(): ) -loop.run_until_complete(main()) +asyncio.run(main()) diff --git a/examples/dbus-next-send.py b/examples/dbus-next-send.py index 1fe48b5..a682099 100755 --- a/examples/dbus-next-send.py +++ b/examples/dbus-next-send.py @@ -101,8 +101,6 @@ else: if not signature: exit_error("--signature is a required argument when passing a message body") -loop = asyncio.get_running_loop() - async def main(): bus = await MessageBus(bus_type=bus_type).connect() @@ -135,4 +133,4 @@ async def main(): sys.exit(ret) -loop.run_until_complete(main()) +asyncio.run(main()) diff --git a/examples/example-service.py b/examples/example-service.py index a34ac6a..ef7f3f5 100755 --- a/examples/example-service.py +++ b/examples/example-service.py @@ -64,4 +64,4 @@ async def main(): await bus.wait_for_disconnect() -asyncio.get_running_loop().run_until_complete(main()) +asyncio.run(main()) diff --git a/examples/mpris.py b/examples/mpris.py index 3b26b68..a8d0b88 100755 --- a/examples/mpris.py +++ b/examples/mpris.py @@ -8,8 +8,6 @@ import asyncio from dbus_fast.aio import MessageBus -loop = asyncio.get_running_loop() - async def main(): bus = await MessageBus().connect() @@ -45,4 +43,4 @@ async def main(): await bus.wait_for_disconnect() -loop.run_until_complete(main()) +asyncio.run(main())