lib/csv_piper/piper.rb in csv_piper-0.1.6 vs lib/csv_piper/piper.rb in csv_piper-0.1.7
- old
+ new
@@ -35,15 +35,15 @@
attr_reader :io, :pre_processors, :processors, :required_headers, :csv_options
def process_csv_body
csv.each.with_index(FIRST_DATA_LINE_INDEX) do |row, index|
- processed_data, row_errors = process_row(index, row.to_hash)
+ processed_data, row_errors = process_row(row.to_hash, Errors::Row.new(index))
end
end
- def process_row(row_index, row)
- pre_processed_row, row_errors = pre_processors.reduce([row, Errors::Row.new(row_index)]) do |memo, processor|
+ def process_row(row, row_errors)
+ pre_processed_row, row_errors = pre_processors.reduce([row, row_errors]) do |memo, processor|
output = processor.process(*memo)
return if output.nil?
output
end