SSE Stream Aggregator