def buffer_streamer(streamer, buffer_size, *args, **kwargs):
    for batch in buffer_batch(streamer.generate(*args, **kwargs),
                              buffer_size):
        yield batch
Buffer a stream of batches
dataset/ETHPy150Open bmcfee/pescador/pescador/util.py/buffer_streamer