private boolean skipItemsOnReader ( PeekingInputReader < KeyValue < ByteBuffer , ? extends Iterable < V > > > reader ) { boolean itemSkipped = false ; KeyValue < ByteBuffer , ? extends Iterable < V > > keyValue = reader . peek ( ) ; while ( keyValue != null && compareBuffers ( keyValue . getKey ( ) , lastKey . getValue ( ) ) == 0 ) { consumePeekedValueFromReader ( keyValue , reader ) ; itemSkipped = true ; keyValue = reader . peek ( ) ; } return itemSkipped ; }
Helper function for skipLeftoverItems to skip items matching last key on a single reader .