def reduce_by_key(self, func):
        return self._transform(transformations.reduce_by_key_t(func))
Perform all work currently scheduled in the coordinator.
dataset/ETHPy150Open EntilZha/PyFunctional/functional/pipeline.py/Sequence.reduce_by_key--crossover with--dataset/ETHPy150Open twisted/twisted/twisted/_threads/test/test_team.py/TeamTests.coordinate