def buffer_streamer(streamer, buffer_size, *args, **kwargs):
    for batch in buffer_batch(streamer.generate(*args, **kwargs),
                              buffer_size):
        yield batch
Fit
dataset/ETHPy150Open bmcfee/pescador/pescador/util.py/buffer_streamer--crossover with--dataset/ETHPy150Open slinderman/pyhawkes/experiments/chalearn_small_comparison.py/fit_standard_hawkes_model_bfgs