Method: Traject::NDJReader#initialize

Defined in:
lib/traject/ndj_reader.rb

#initialize(input_stream, settings) ⇒ NDJReader

Returns a new instance of NDJReader.



12
13
14
15
16
17
18
 
# File 'lib/traject/ndj_reader.rb', line 12

def initialize(input_stream, settings)
  @settings = settings
  @input_stream = input_stream
  if input_stream.respond_to?(:path) && /\.gz\Z/.match(input_stream.path)
    @input_stream = Zlib::GzipReader.new(@input_stream, :external_encoding => "UTF-8")
  end
end