code: def on_message(self, message):
          
          log.debug('Got websocket message %s', message)
          if message == 'websocket client ready':
              if self.connected:
                  # TBD: Add ability to run commands in this branch
                  log.debug('Websocket already connected, returning')
                  return
  
              self.connected = True
  
              while True:
                  try:
                      event = yield self.application.event_listener.get_event(self)
                      self.write_message(
                          salt.utils.json.dumps(event, _json_module=_json))
                  except Exception as err:
                      log.info('Error! Ending server side websocket connection. Reason = %s', err)
                      break
  
              self.close()
          else:
              # TBD: Add logic to run salt commands here
              pass
docs: Listens for a "websocket client ready" message.
          Once that message is received an asynchronous job
          is stated that yields messages to the client.
          These messages make up salt's
          "real time" event stream.