examples: mqtt: fix pub_sub

Author: rnovatorov

examples/mqtt/pub_sub.py

@@ -6,10 +6,10 @@
 
 async def main() -> None:
     config = enapter.mqtt.Config(host="127.0.0.1", port=1883)
-    async with enapter.mqtt.Client(config=config) as client:
-        async with asyncio.TaskGroup() as tg:
-            tg.create_task(subscriber(client))
-            tg.create_task(publisher(client))
+    async with asyncio.TaskGroup() as tg:
+        client = enapter.mqtt.Client(tg, config=config)
+        tg.create_task(subscriber(client))
+        tg.create_task(publisher(client))
 
 
 async def subscriber(client: enapter.mqtt.Client) -> None:
@@ -28,4 +28,7 @@ async def publisher(client: enapter.mqtt.Client) -> None:
 
 
 if __name__ == "__main__":
-    asyncio.run(main())
+    try:
+        asyncio.run(main())
+    except KeyboardInterrupt:
+        pass