docs: def socket_worker(sock, msg_q):
      """Socket Loop that fills message queue"""
      _LOGGER.debug("Starting Socket Thread.")
      while True:
          try:
              data, addr = sock.recvfrom(1024)    # buffer size is 1024 bytes
          except OSError as err:
              _LOGGER.error(err)
          else:
              _LOGGER.debug("received message: %s from %s", data, addr)
              msg_q.put(data)
          time.sleep(0.2)