orion/purescript-csv-stream
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix: what

Browse Source
This commit is contained in:
orion 2024-05-03 14:22:07 -05:00
parent 39276c2546
commit 52dd297c9c
Signed by: orion
GPG Key ID: 6D4165AE4C928719
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/Node.Stream.CSV.Parse.purs
View File

@ -120,9 +120,11 @@ foreach stream cb = do
alreadyHaveCols <- liftEffect $ getOrInitColumnsMap stream alreadyHaveCols <- liftEffect $ getOrInitColumnsMap stream
when (isNothing alreadyHaveCols) when (isNothing alreadyHaveCols)
$ liftAff $ liftAff
$ makeAff \res -> pure mempty <* flip (Event.once columnsH) stream $ const do $ makeAff \res -> do
void $ getOrInitColumnsMap stream stop <- flip (Event.once columnsH) stream $ const do
res $ Right unit void $ getOrInitColumnsMap stream
res $ Right unit
pure $ Canceler $ const $ liftEffect stop
liftAff $ makeAff \res -> do liftAff $ makeAff \res -> do
removeDataListener <- flip (Event.on dataH) stream \row -> launchAff_ $ delay (wrap 0.0) <* liftEffect do removeDataListener <- flip (Event.on dataH) stream \row -> launchAff_ $ delay (wrap 0.0) <* liftEffect do