def METHOD_NAME(self):
    for length in [20, 50, 100]:
        results = []
        ait = self.get_async_iterable_with_delays(length)
        dl = parallel_async(ait, self.CONCURRENT_ITEMS, self.callable, results)
        yield dl
        self.assertEqual(list(range(length)), sorted(results))