Added individual count accumulator for each stream to fixed race condition.