(lhs: &MergeRow, rhs: &MergeRow)
| 138 | pub(crate) struct DeduplicateMergeFunction; |
| 139 | |
| 140 | fn compare_sequence_order(lhs: &MergeRow, rhs: &MergeRow) -> Ordering { |
| 141 | match (lhs.user_sequences.is_empty(), rhs.user_sequences.is_empty()) { |
| 142 | (false, false) => lhs |
| 143 | .user_sequences |
| 144 | .cmp(&rhs.user_sequences) |
| 145 | .then_with(|| lhs.sequence_number.cmp(&rhs.sequence_number)), |
| 146 | _ => lhs.sequence_number.cmp(&rhs.sequence_number), |
| 147 | } |
| 148 | } |
| 149 | |
| 150 | impl MergeFunction for DeduplicateMergeFunction { |
| 151 | fn merge( |