Streams consolidationStreams consolidation