diff --git a/src/Node.Stream.CSV.Parse.purs b/src/Node.Stream.CSV.Parse.purs
index 6132320..ffecbf3 100644
--- a/src/Node.Stream.CSV.Parse.purs
+++ b/src/Node.Stream.CSV.Parse.purs
@@ -150,7 +150,7 @@ foreach stream cb =
               else do
                 r' <- MaybeT $ pure r
                 lift $ cb r'
-                pure unit
+                empty
 
       readToQ =
         whileJust