fix: bug

2024-05-03 12:58:52 -05:00 · 2024-05-03 12:58:52 -05:00 · 874503a300
commit 874503a300
parent 05b61d84f0
1 changed files with 1 additions and 1 deletions
--- a/src/Node.Stream.CSV.Parse.purs
+++ b/src/Node.Stream.CSV.Parse.purs
@ -146,10 +146,10 @@ foreach stream cb =
                pure unit
              else if isNothing r then
                liftAff $ delay $ wrap 10.0
+                empty
              else do
                r' <- MaybeT $ pure r
                lift $ cb r'
-                guard $ isClosed
                pure unit

      readToQ =