Minor refactor in StreamMerger