diff --git a/package.json b/package.json
index bc35228..38de967 100644
--- a/package.json
+++ b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "purescript-csv-stream",
-  "version": "v1.2.4",
+  "version": "v1.2.5",
   "dependencies": {
     "csv-parse": "^5.5.5",
     "csv-stringify": "^6.4.6"
diff --git a/spago.yaml b/spago.yaml
index 162d9d9..f176e5d 100644
--- a/spago.yaml
+++ b/spago.yaml
@@ -1,7 +1,7 @@
 package:
   name: csv-stream
   publish:
-    version: '1.2.4'
+    version: '1.2.5'
     license: 'GPL-3.0-or-later'
     location:
       githubOwner: 'cakekindel'
diff --git a/src/Node.Stream.CSV.Parse.purs b/src/Node.Stream.CSV.Parse.purs
index d774763..6132320 100644
--- a/src/Node.Stream.CSV.Parse.purs
+++ b/src/Node.Stream.CSV.Parse.purs
@@ -3,7 +3,7 @@ module Node.Stream.CSV.Parse where
 import Prelude hiding (join)
 
 import Control.Alt ((<|>))
-import Control.Alternative (guard)
+import Control.Alternative (guard, empty)
 import Control.Monad.Error.Class (liftEither)
 import Control.Monad.Except (runExcept)
 import Control.Monad.Maybe.Trans (MaybeT(..), runMaybeT)
@@ -144,7 +144,7 @@ foreach stream cb =
               isClosed <- liftEffect $ Stream.closed stream
               if isClosed && isNothing r then
                 pure unit
-              else if isNothing r then
+              else if isNothing r then do
                 liftAff $ delay $ wrap 10.0
                 empty
               else do