def __init__(self, stream):

        self.stream = stream
        self.remain = 0
Add accumulator to the moving average queue and reset it. For
dataset/ETHPy150Open d11wtq/dockerpty/dockerpty/io.py/Demuxer.__init__--crossover with--dataset/ETHPy150Open flaviogrossi/sockjs-cyclone/sockjs/cyclone/stats.py/MovingAverage.flush