auto commit

wsps/consumers.py

@@ -10,7 +10,8 @@ p=print
 
 # class ChatConsumer(WebsocketConsumer,wsps.tasks_loop.AclTaskMixin,wsps.tasks_loop.AconMixin):
 class ChatConsumer(AsyncWebsocketConsumer,wsps.tasks_loop.AclTaskMixin,wsps.tasks_loop.AconMixin):
-    def connect(self):
+    # def connect(self):
+    async def ws_conn(self):
         p("!!!!!!!!!!!!!!!!!!!!?")
         print("",end="",flush=True)
         # time.sleep(1.5)
@@ -19,10 +20,10 @@ class ChatConsumer(AsyncWebsocketConsumer,wsps.tasks_loop.AclTaskMixin,wsps.task
         # print("",end="",flush=True)
         self.accept()
 
-    def disconnect(self, close_code):
+    async def ws_disconn(self, close_code):
         pass
 
-    def receive(self, text_data):
+    async def ws_rec(self, text_data):
         p("text_data:",text_data)
         print("",end="",flush=True)
         text_data_json = json.loads(text_data)