code: def fanout_message(connections, payload):
      
      for conn in connections:
          try:
              yield from conn.send(json.dumps(payload))
          except Exception as e:
              logger.debug('could not send', e)
docs: Distributes payload (message) to all connected ws clients