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

fix: maybe this has already been emitted

Browse Source
This commit is contained in:
orion 2024-05-03 14:05:51 -05:00
parent 6b28c7fdf7
commit 8ba33e88cf
Signed by: orion
GPG Key ID: 6D4165AE4C928719
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -17,7 +17,7 @@ import Data.Either (Either(..))
import Data.Filterable (filter) import Data.Filterable (filter)
import Data.Map (Map) import Data.Map (Map)
import Data.Map as Map import Data.Map as Map
import Data.Maybe (Maybe(..)) import Data.Maybe (Maybe(..), isNothing)
import Data.Newtype (wrap) import Data.Newtype (wrap)
import Data.Nullable (Nullable) import Data.Nullable (Nullable)
import Data.Nullable as Nullable import Data.Nullable as Nullable
@ -117,7 +117,10 @@ foreach
foreach stream cb = do foreach stream cb = do
UnliftAff unlift <- askUnliftAff UnliftAff unlift <- askUnliftAff
liftAff $ makeAff \res -> pure mempty <* flip (Event.once columnsH) stream $ const do alreadyHaveCols <- liftEffect $ getOrInitColumnsMap stream
when (isNothing alreadyHaveCols)
$ liftAff
$ makeAff \res -> pure mempty <* flip (Event.once columnsH) stream $ const do
void $ getOrInitColumnsMap stream void $ getOrInitColumnsMap stream
res $ Right unit res $ Right unit