Browse Source

auto commit

master
jfinn 3 years ago
parent
commit
08ee643389
1 changed files with 9 additions and 1 deletions
  1. 9
    1
      wsps/tasks_loop.py

+ 9
- 1
wsps/tasks_loop.py View File

248
 	run_persistent_loop = _run_persistent_loop
248
 	run_persistent_loop = _run_persistent_loop
249
 
249
 
250
 
250
 
251
+	def sync_dev_group_discard(self,*a,**kw):
252
+		glob_cl.cbs_once.append(self.sync_dev_group_discard(*a,**kw))
253
+	async def dev_group_discard(self,group_name,consumer):
254
+		channel_layer = glob_cl.acl
255
+		if consumer.channel_name in consumer.groups:
256
+			consumer.groups.remove(group_name)
257
+		await channel_layer.group_discard(group_name,consumer.channel_name)
258
+
251
 	def sync_dev_group_add(self,*a,**kw):
259
 	def sync_dev_group_add(self,*a,**kw):
252
-		glob_cl.cbs_once.append(group_add(*a,**kw))
260
+		glob_cl.cbs_once.append(self.group_add(*a,**kw))
253
 	async def dev_group_add(self,group_name,consumer):
261
 	async def dev_group_add(self,group_name,consumer):
254
 		channel_layer = glob_cl.acl
262
 		channel_layer = glob_cl.acl
255
 		# if not consumer.channel_name in consumer.groups_set:
263
 		# if not consumer.channel_name in consumer.groups_set:

Loading…
Cancel
Save