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