def METHOD_NAME(self):
    count = 0
    while count < 10:
        count += 1
        try:
            datagram = self._socket.recv(QUIC_MAX_DATAGRAM)
        except BlockingIOError:
            return
        with self._lock:
            self._connection.receive_datagram(datagram, self._peer[0], time.time())