Switched to the new Async API

git-svn-id: https://redmine.imt-atlantique.fr/svn/xaal/code/Python/branches/0.7@2851 b32b6428-25c9-4566-ad07-03861ab6144f

devices/protocols/SenseFloor/xaal/sensefloor/__main__.py

 from . import gw
 from xaal.lib import helpers
-from xaal.lib.asyncio import AsyncEngine
 
 
-#helpers.run_package(gw.PACKAGE_NAME,gw.setup)
-helpers.setup_console_logger(gw.PACKAGE_NAME)
-gw.run()
+helpers.run_async_package(gw.PACKAGE_NAME,gw.setup)

devices/protocols/SenseFloor/xaal/sensefloor/gw.py

-from xaal.lib import tools,Device
-from xaal.lib.asyncio import AsyncEngine
+from xaal.lib import tools,Device,AsyncEngine
 from xaal.schemas import devices
 
 
@@ -102,8 +101,8 @@ class GW(object):
             logger.info('Saving configuration file')
             self.cfg.write()
 
-    async def xaal_task(self):
-        await self.engine.run()
+#    async def xaal_task(self):
+#        await self.engine.run()
 
     async def sio_task(self):
         url = self.cfg['config']['url']
@@ -111,13 +110,12 @@ class GW(object):
         await self.sio.wait()
 
 
-def run():
-    eng = AsyncEngine()
+def stop():
+    import pdb;pdb.set_trace()
+
+
+def setup(eng):
     gw = GW(eng)
-    asyncio.ensure_future(gw.xaal_task())
-    asyncio.ensure_future(gw.sio_task())
-    loop = asyncio.get_event_loop()
-    try:
+    eng.on_stop(stop)
+    eng.new_task(gw.sio_task())
+    return True
\ No newline at end of file
-        loop.run_forever()
-    except KeyboardInterrupt:
-        print('Bye')