adding aggregator strategy based on streams