code: async def publish(self, message):
          
          try:
              self.write_message(dict(data=message))
          except WebSocketClosedError:
              self._close()
docs: Push a new message to the client. The data will be
          available as a JSON object with the key ``data``.