diff --git a/lib/Pear/LocalLoop/Import/LCCCsv/Suppliers.pm b/lib/Pear/LocalLoop/Import/LCCCsv/Suppliers.pm
index 678c6c5..c191534 100644
--- a/lib/Pear/LocalLoop/Import/LCCCsv/Suppliers.pm
+++ b/lib/Pear/LocalLoop/Import/LCCCsv/Suppliers.pm
@@ -13,9 +13,9 @@ has '+csv_required_columns' => (
 sub import_csv {
   my ($self) = @_;
 
-  my $rows = $self->csv_data;
+  $self->check_headers;
 
-  foreach my $row ( @{$rows} ) {
+  while ( my $row = $self->get_csv_line ) {
     $self->_row_to_result($row);
   }
 }
diff --git a/lib/Pear/LocalLoop/Import/LCCCsv/Transactions.pm b/lib/Pear/LocalLoop/Import/LCCCsv/Transactions.pm
index 026806e..34ba039 100644
--- a/lib/Pear/LocalLoop/Import/LCCCsv/Transactions.pm
+++ b/lib/Pear/LocalLoop/Import/LCCCsv/Transactions.pm
@@ -35,10 +35,10 @@ has '+csv_required_columns' => (
 sub import_csv {
   my ($self) = @_;
 
-  my $rows = $self->csv_data;
+  $self->check_headers;
   my $lcc_org = $self->target_entity;
 
-  foreach my $row (@{$rows}) {
+  while ( my $row = $self->get_csv_line ) {
     $self->_row_to_result($row, $lcc_org);
   }
 }