'Blocks until all results are done (please note the .get())'

def map_multi_args(self, func, iterable, chunksize=None):

    assert (self._state == RUN)
    return self.map_async(one_to_many(func), iterable, chunksize).get()
