Fixup after merge with master
commitaaf8d2c45b310144cac1f37367240594897dfe8f
authorHarendra Kumar <harendra.kumar@gmail.com>
dateSat 29 Dec 2018, 16:56 (8 years ago)
parent9f43f1a
benchmark/BaseStreams.hs+1−1
@@ -46,7 +46,7 @@ main =
4646 [ bgroup "generation"
4747 [ benchIO "unfoldr" D.toNull D.sourceUnfoldr
4848 , benchIO "unfoldrM" D.toNull D.sourceUnfoldrM
49− , benchIO "fromEnum" D.toNull D.sourceFromEnum
49+ , benchIO "intFromTo" D.toNull D.sourceIntFromTo
5050
5151 , benchIO "fromList" D.toNull D.sourceFromList
5252 -- , benchIO "fromFoldableM" D.sourceFromFoldableM
benchmark/StreamDOps.hs+3−3
@@ -57,9 +57,9 @@ sourceUnfoldrM n = S.unfoldrM step n
5757 then return Nothing
5858 else return (Just (cnt, cnt + 1))
5959
60−{-# INLINE sourceFromEnum #-}
61−sourceFromEnum :: Monad m => Int -> Stream m Int
62−sourceFromEnum n = S.intFromTo n (n + value)
60+{-# INLINE sourceIntFromTo #-}
61+sourceIntFromTo :: Monad m => Int -> Stream m Int
62+sourceIntFromTo n = S.enumerateFromToIntegral n (n + value)
6363
6464{-# INLINE sourceFromList #-}
6565sourceFromList :: Monad m => Int -> Stream m Int
src/Streamly/Prelude.hs+1−1
@@ -358,7 +358,7 @@ import qualified Prelude
358358import qualified System.IO as IO
359359
360360import Streamly.Enumeration (Enumerable(..), enumerate, enumerateTo)
361−import Streamly.SVar (MonadAsync, defState, rstState)
361+import Streamly.SVar (MonadAsync, defState)
362362import Streamly.Streams.Async (mkAsync')
363363import Streamly.Streams.Combinators (maxYields)
364364import Streamly.Streams.Prelude (fromStreamS, toStreamS)
src/Streamly/Streams/Prelude.hs+1−1
@@ -83,7 +83,7 @@ toStreamS = S.fromStreamK . toStream
8383{-# INLINE_EARLY runStream #-}
8484runStream :: (IsStream t, Monad m) => t m a -> m ()
8585runStream m = D.runStream $ D.fromStreamK (toStream m)
86−{-# RULES "run fallback to CPS" [1]
86+{-# RULES "runStream fallback to CPS" [1]
8787 forall a. D.runStream (D.fromStreamK a) = K.runStream a #-}
8888
8989------------------------------------------------------------------------------