

@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/original