Accumulation done per stream