Method: Traject::MockReader#initialize

Defined in:
lib/traject/mock_reader.rb

#initialize(input_stream, settings = {}) ⇒ MockReader

Returns a new instance of MockReader.

Parameters:

  • input_stream (Ignored) —

    (ignored)

  • settings (Hash) (defaults to: {}) —

    (looks only for an integer in 'mock_reader.limit')



27
28
29
30
31
32
33
34
 
# File 'lib/traject/mock_reader.rb', line 27

def initialize(input_stream, settings = {})
  @limit = (settings["mock_reader.limit"]  || 10_000).to_i

  @records = load_ndjson(File.open(__FILE__))

  # freeze it immutable for thread safety and performance
  @records.each {|r| r.fields.freeze}
end