(self)
| 1447 | ) |
| 1448 | |
| 1449 | def group(self): |
| 1450 | # need to evaluate generators |
| 1451 | task, it, n = self._unpack_args(self.kwargs) |
| 1452 | return group((xstarmap(task, part, app=self._app) |
| 1453 | for part in _chunks(iter(it), n)), |
| 1454 | app=self._app) |
| 1455 | |
| 1456 | @classmethod |
| 1457 | def apply_chunks(cls, task, it, n, app=None): |