Skip to content

Commit 254018a

Browse files
Upgrade streamly-core to version 0.2.0
1 parent bea1b65 commit 254018a

2 files changed

Lines changed: 4 additions & 3 deletions

File tree

src/Aggregator.hs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,7 @@ newtype Window = Window (Set Word32) -- thread ids that have joined the window
5252

5353
{-# INLINE translateThreadEvents #-}
5454
translateThreadEvents :: Fold IO Event [Event]
55-
translateThreadEvents = Fold step initial extract
55+
translateThreadEvents = Fold step initial extract extract
5656

5757
where
5858

@@ -204,7 +204,7 @@ data CollectState =
204204
collectThreadCounter ::
205205
Fold IO ((Word32, String, Counter), (Location, Int64))
206206
(Maybe (Either (Maybe Int64) Int64))
207-
collectThreadCounter = Fold step initial extract
207+
collectThreadCounter = Fold step initial extract extract
208208

209209
where
210210

src/EventParser.hs

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,8 @@ import Streamly.Data.Parser (Parser)
1919
import Streamly.Data.ParserK (ParserK)
2020
import Streamly.Data.Stream (Stream)
2121
import Streamly.Data.StreamK (StreamK)
22-
import Streamly.Internal.Serialize.FromBytes (int16be, word16be, word32be, word64be)
22+
import Streamly.Internal.Data.Binary.Parser
23+
(int16be, word16be, word32be, word64be)
2324

2425
import qualified Data.IntMap as Map
2526
import qualified Streamly.Data.Array as Array

0 commit comments

Comments
 (0)