Assuming the aggregators aren't polling (so the only way aggregation is invoked is by executing `collectAndGetActivityStream`) which should be the case in the tests, if `client.on` and `ActivityTestsUtil.collectAndGetActivityStream` are invoked in the same process tick, no race condition is possible.