gistfile1.txt

from channels.consumer import SyncConsumer, AsyncConsumer
from channels.exceptions import StopConsumer
from asgiref.sync import async_to_sync
class MySyncConsumer(SyncConsumer):
    def websocket_connect(self, event):
        async_to_sync(self.channel_layer.group_add)('programmers',
        self.channel_name)
        self.send({
        'type':'websocket.accept'
        })
    def websocket_receive(self, event):
        async_to_sync(self.channel_layer.group_send)('programmers', {
        'type':'chat.message',
        'message':event['text']
        })
    def websocket_disconnect(self, event):
        print('websocker disconnect', event)
        def chat_message(self, event):
        self.send({'type':'websocket.send',
        'text':event['message']})