Upgrade streamly-core to version 0.2.0

composewell · Dec 6, 2023 · 254018a · 254018a
1 parent bea1b65
commit 254018a
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/src/Aggregator.hs b/src/Aggregator.hs
@@ -52,7 +52,7 @@ newtype Window = Window (Set Word32) -- thread ids that have joined the window
 
 {-# INLINE translateThreadEvents #-}
 translateThreadEvents :: Fold IO Event [Event]
-translateThreadEvents = Fold step initial extract
+translateThreadEvents = Fold step initial extract extract
 
     where
 
@@ -204,7 +204,7 @@ data CollectState =
 collectThreadCounter ::
     Fold IO ((Word32, String, Counter), (Location, Int64))
     (Maybe (Either (Maybe Int64) Int64))
-collectThreadCounter = Fold step initial extract
+collectThreadCounter = Fold step initial extract extract
 
     where
 

diff --git a/src/EventParser.hs b/src/EventParser.hs
@@ -19,7 +19,8 @@ import Streamly.Data.Parser (Parser)
 import Streamly.Data.ParserK (ParserK)
 import Streamly.Data.Stream (Stream)
 import Streamly.Data.StreamK (StreamK)
-import Streamly.Internal.Serialize.FromBytes (int16be, word16be, word32be, word64be)
+import Streamly.Internal.Data.Binary.Parser
+    (int16be, word16be, word32be, word64be)
 
 import qualified Data.IntMap as Map
 import qualified Streamly.Data.Array as Array