Method: Fairy::PGroupBy::DirectKBMergeSortBuffer::CachedBuffer#each_by_same_key

Defined in:
lib/fairy/node/p-group-by.rb

#each_by_same_key(&block) ⇒ Object



1407
1408
1409
1410
1411
1412
1413
1414
1415
1416
1417
# File 'lib/fairy/node/p-group-by.rb', line 1407

def each_by_same_key(&block)
  loop do
    @cache.each &block
    read_buffer
    return if @cache.empty?
    unless @njob.hash_key(@cache.first) == @key
      @key = @njob.hash_key(@cache.first)
      return
    end
  end
end