Function merge_sorted_streams 

pub fn merge_sorted_streams<'g>(
    streams: Vec<RowFlow<'g>>,
    sort: Sort,
    reverse: bool,
) -> RowFlow<'g>

K-way min-heap merge of pre-sorted row streams under the reverse-aware comparator. Drop-clean (early close drops every sub-stream — §5.5).