@@ -399,7 +399,7 @@ impl<C: CursorValues> SortPreservingMergeStream<C> {
399399 /// between the current winner and a challenger. This function is invoked when such a tie needs to be
400400 /// resolved according to the round-robin tie-breaker mode.
401401 ///
402- /// If round-robin tie-breaking is not active, it is enabled, and the poll counts for all elements are reset.
402+ /// If round-robin tie-breaking is not active and the poll counts for all elements are reset.
403403 /// The function then compares the poll counts of the current winner and the challenger:
404404 /// - If the winner remains at the top after the final comparison, it increments the winner's poll count.
405405 /// - If the challenger has a lower poll count than the current winner, the challenger becomes the new winner.
@@ -410,7 +410,7 @@ impl<C: CursorValues> SortPreservingMergeStream<C> {
410410 /// - `winner`: A mutable reference to the current winner, which may be updated based on the tie-breaking result.
411411 /// - `challenger`: The index of the challenger being compared against the winner.
412412 ///
413- /// This function ensures fair selection among elements with equal values when tie-breaking mode is enabled,
413+ /// This function ensures fair selection among elements with equal values
414414 /// aiming to balance the polling across different partitions.
415415 #[ inline]
416416 fn handle_tie ( & mut self , cmp_node : usize , winner : & mut usize , challenger : usize ) {
@@ -449,7 +449,7 @@ impl<C: CursorValues> SortPreservingMergeStream<C> {
449449 // Traverse up the tree to adjust comparisons until reaching the root.
450450 while cmp_node != 0 {
451451 let challenger = self . loser_tree [ cmp_node] ;
452- // If round-robin tie-breaker is enabled and we're at the final comparison (cmp_node == 1)
452+ // If we're at the final comparison (cmp_node == 1)
453453 if cmp_node == 1 {
454454 match ( & self . cursors [ winner] , & self . cursors [ challenger] ) {
455455 ( Some ( ac) , Some ( bc) ) => {
0 commit comments