in pythonflow/util.py [0:0]
def __iter__(self):
batch = []
for item in self.iterable:
batch.append(item)
if len(batch) == self.batch_size:
yield tuple(zip(*batch)) if self.transpose else batch
batch = []
if batch:
yield tuple(zip(*batch)) if self.transpose else batch