https://softwarepatternslexicon.com/stream-processing/aggregation-patterns/conditional-aggregation/