@implementation
    def test_aggregate(self):
        aggregator = self.aggregator_class()
        activities = self.first_activities_group % self.second_activities_group
        aggregated = aggregator.aggregate(activities)
        self.assertEqual(len(aggregated), 2)
        self.assertEqual(aggregated[0].activities, self.first_activities_group)
        self.assertEqual(aggregated[1].activities, self.second_activities_group)
dataset/ETHPy150Open tschellenbach/Stream-Framework/stream_framework/tests/aggregators/__init__.py/BaseAggregatorTest.test_aggregate/operator `+` -> `%`