Merge pull request #39 from MarSoft/fix-service-example

Fix race condition in examples for high level service interface

Author: Tony Crisci

README.md

@@ -117,9 +117,11 @@ class ExampleInterface(ServiceInterface):
 
 async def main():
     bus = await MessageBus().connect()
-    await bus.request_name('test.name')
     interface = ExampleInterface('test.interface')
     bus.export('/test/path', interface)
+    # 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_event_loop().create_future()
 
 asyncio.get_event_loop().run_until_complete(main())

docs/high-level-service/index.rst

@@ -77,9 +77,9 @@ After the service interface is defined, call :func:`MessageBus.export() <dbus_ne
 
     async def main():
         bus = await MessageBus().connect()
-        await bus.request_name('com.example.name')
         interface = ExampleInterface()
         bus.export('/com/example/sample0', interface)
+        await bus.request_name('com.example.name')
 
         # emit the changed signal after two seconds.
         await asyncio.sleep(2)

examples/example-service.py

@@ -54,9 +54,9 @@ async def main():
     interface_name = 'example.interface'
 
     bus = await MessageBus().connect()
-    await bus.request_name(name)
     interface = ExampleInterface(interface_name)
     bus.export('/example/path', interface)
+    await bus.request_name(name)
     print(f'service up on name: "{name}", path: "{path}", interface: "{interface_name}"')
     await asyncio.get_event_loop().create_future()