(acc, new, agg=None)
return agg.on_new(acc, new)
An accumulation binary operator

    This is the function that is actually given to the ``Stream.accumulate``
    function.

    See Also
    --------
    windowed_accumulator
    windowed_groupby_accumulator
An accumulation binary operator
An accumulation binary operator
def accumulator(acc, new, agg=None):
    """ An accumulation binary operator

    This is the function that is actually given to the ``Stream.accumulate``
    function.

    See Also
    --------
    windowed_accumulator
    windowed_groupby_accumulator
    """
    if acc is None:
        acc = agg.initial(new)
    return agg.on_new(acc, new)
def accumulator ( acc , new , agg = None ) : if acc is None : acc = agg . initial ( new ) return agg . on_new ( acc , new )