'Loop on `self.check.method` until `self.check.attribute >= count`.
Raise after'

def wait_for_async(self, method, attribute, count, results_timeout):

    initial_values = getattr(self, attribute)
    i = 0
    while (i < results_timeout):
        self.check._process_results()
        if ((len(getattr(self.check, attribute)) + len(initial_values)) >= count):
            return (getattr(self.check, method)() + initial_values)
        time.sleep(1.1)
        i += 1
    raise Exception("Didn't    get    the    right    count    of    service    checks    in    time,    {0}/{1}    in    {2}s:    {3}".format(len(getattr(self.check, attribute)), count, i, getattr(self.check, attribute)))
