Aggregating streaming transactions