minor changes

example.py

@@ -80,12 +80,12 @@ def test(o):
         self <= Tag.button("B",_onclick=test)
 
 
-
-
+async def serve(req):
+    return await req.app.handle(req,Jo,http_only=True,parano=True) 
 #------------------------------------------------------
 from htagweb import SimpleServer,AppServer
 app=AppServer( App, timeout_inactivity=0 )
-app.add_route("/jo", lambda req: req.app.handle(req,Jo,http_only=True,parano=True) )
+app.add_route("/jo", serve)
 
 if __name__=="__main__":
     #~ import logging

htagweb/appserver.py

@@ -147,7 +147,7 @@ async def on_connect(self, websocket):
         await websocket.accept()
 
         # add the loop to tag.update feature
-        asyncio.ensure_future(self.hr.loop_tag_update(self, websocket))
+        self.task = asyncio.create_task(self.hr.loop_tag_update(self, websocket))
 
     async def on_receive(self, websocket, data):
         if self.is_parano:
@@ -159,6 +159,7 @@ async def on_receive(self, websocket, data):
         await self._sendback( websocket, json.dumps(actions) )
 
     async def on_disconnect(self, websocket, close_code):
+        self.task.cancel()
         with redys.v2.AClient() as bus:
             await bus.unsubscribe(self.hr.hid.EVENT_RESPONSE_UPDATE)
 

htagweb/server/__init__.py

@@ -309,17 +309,9 @@ async def stopServer(s):
     # clean all running process
     await killall()
 
-
     # before stopping
     s.stop()
 
-    bus=redys.v2.AClient()
-    while 1:
-        try:
-            await bus.ping()
-        except:
-            break
-        await asyncio.sleep(0.1)
 
 if __name__=="__main__":
     # asyncio.run( hrserver() )

htagweb/server/client.py

@@ -144,6 +144,7 @@ async def loop_tag_update(self, hrsocket, websocket):
                     if not can:
                         break
                 await asyncio.sleep(0.1)
-        except:
+        except Exception as e:
             print("**loop_tag_update, broken bus, will stop the loop_tag_update !**")
-
+        finally:
+            await self._bus.unsubscribe(event)