A stream transformer applying an aggregation operation every time one of the streams emit a new piece of data