Class: Orbacle::Indexer::ReadingProcess

Inherits:
Object
  • Object
show all
Defined in:
lib/orbacle/indexer.rb

Instance Method Summary collapse

Constructor Details

#initialize(logger, queue, files) ⇒ ReadingProcess

Returns a new instance of ReadingProcess.



47
48
49
50
51
# File 'lib/orbacle/indexer.rb', line 47

def initialize(logger, queue, files)
  @logger = logger
  @queue = queue
  @files = files
end

Instance Method Details

#callObject



53
54
55
56
57
58
59
# File 'lib/orbacle/indexer.rb', line 53

def call
  @files.each do |file_path|
    file_content = File.read(file_path)
    @queue.push(QueueElement.new(file_content, file_path))
  end
  @queue.close
end