parallel_consume

atqo.parallel_consume(Actor: type[atqo.bases.ActorBase], iterable, dist_api='mp', batch_size=None, min_queue_size=None, workers=None, raise_errors=True, verbose=False, pbar=False, allowed_fail_count=0)