Class: Contrek::Concurrent::VerticalMerger

Inherits:
Merger show all
Defined in:
lib/contrek/finder/concurrent/vertical_merger.rb

Direct Known Subclasses

StreamingMerger

Instance Attribute Summary

Attributes inherited from Merger

#tiles

Attributes included from Poolable

#number_of_threads

Attributes inherited from Finder

#maximum_width, #options

Instance Method Summary collapse

Methods inherited from Merger

#initialize

Methods included from Poolable

#enqueue!, #initialize, #wait!

Methods inherited from Finder

#initialize

Constructor Details

This class inherits a constructor from Contrek::Concurrent::Merger

Instance Method Details

#add_tile(result) ⇒ Object 



6
7
8
9
10
11
12
13
 
# File 'lib/contrek/finder/concurrent/vertical_merger.rb', line 6

def add_tile(result)
  transpose(result)
  if @tiles.size > 0
    translate(result, @current_x)
  end
  adjust(result)
  super
end

#process_info(flush: false) ⇒ Object 



15
16
17
 
# File 'lib/contrek/finder/concurrent/vertical_merger.rb', line 15

def process_info(flush: false)
  transpose(super())
end

#transpose? ⇒ Boolean

Returns:

  • (Boolean) 


19
20
21
 
# File 'lib/contrek/finder/concurrent/vertical_merger.rb', line 19

def transpose?
  true
end