From c94adacc1a3b1f27d7c23f4be014a248d521fc24 Mon Sep 17 00:00:00 2001 From: Orion Kindel Date: Fri, 3 May 2024 14:34:08 -0500 Subject: [PATCH] fix: timeslice shenanigans --- src/Node.Stream.CSV.Parse.purs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/Node.Stream.CSV.Parse.purs b/src/Node.Stream.CSV.Parse.purs index 6412848..be6b71b 100644 --- a/src/Node.Stream.CSV.Parse.purs +++ b/src/Node.Stream.CSV.Parse.purs @@ -127,7 +127,7 @@ foreach stream cb = do pure $ Canceler $ const $ liftEffect stop liftAff $ makeAff \res -> do - removeDataListener <- flip (Event.on dataH) stream \row -> launchAff_ $ delay (wrap 0.0) <* liftEffect + removeDataListener <- flip (Event.on dataH) stream \row -> launchAff_ $ delay (wrap 1.0) <* liftEffect ( flip catchError (res <<< Left) do cols <- liftMaybe (error "unreachable") =<< getOrInitColumnsMap stream record <- liftEither $ lmap (error <<< show) $ runExcept $ readCSVRecord @r @rl cols row