707             msg = ''.join(random.choice(all_chars) for _ in range(data))
709             msg = data
711         return AsyncSender(self, src_addr, src_port, dst_addr, dst_port, msg, count, mcast_hops)
733         receiver._add_sender(sender.src_addr, sender.src_port, sender.msg, sender.count)
780     def __init__(self, node, src_addr, src_port, dst_addr, dst_port, msg, count, mcast_hops=None):  argument
786         self._msg = msg
835     def msg(self):  member in AsyncSender
889         def __init__(self, sender_addr, sender_port, msg, count):  argument
892             self._msg = msg
896         def _check_received(self, msg, sender_addr, sender_port):  argument
897 …     if self._msg == msg and self._sender_addr == sender_addr and self._sender_port == sender_port:
926     def _add_sender(self, sender_addr, sender_port, msg, count):  argument
927         self._senders.append(AsyncReceiver._SenderInfo(sender_addr, sender_port, msg, count))
970         (msg, src_sock_addr) = self.recvfrom(AsyncReceiver._MAX_RECV_SIZE)
980             if len(msg) < 30:
981                 info_text = '{} bytes ("{}")'.format(len(msg), msg)
983                 info_text = '{} bytes'.format(len(msg))
987         self._all_rx.append((msg, (src_addr, src_port)))
989         if all([sender._check_received(msg, src_addr, src_port) for sender in self._senders]):