line-decoder-at-parser.rb

def self.transaction(config, &control)
  task = {
    'charset' => 'utf-8',
    'newline' => 'CRLF',  # or LF
  }
  # ...
  yield(task)
end

def run(file_input)
  decoder_task = @task.load_config(Java::LineDecoder::DecoderTask)
  decoder = Java::LineDecoder.new(file_input.instance_eval { @java_file_input }, decoder_task)
  while decoder.nextFile
    puts "parsing a file started"
    while line = decoder.poll
      puts "line: #{line}"
    end
    puts "parsing a file ended"
  end
end