6692959 · streamly · git.iko.soy

git.iko.soy/streamly

on master help sign in

Add some INLINABLE pragams

6692959Harendra Kumar8 years ago

benchmark/LinearOps.hs+1

@@ -155,6 +155,7 @@ composeAllInFilters = compose (S.filter (<= maxValue))

155composeAllOutFilters = compose (S.filter (> maxValue))

156composeMapAllInFilter = compose (S.filter (<= maxValue) . fmap (subtract 1))

157

158+{-# INLINABLE composeScaling #-}

158composeScaling :: Monad m => Int -> Stream m Int -> m ()

159composeScaling :: Monad m => Int -> Stream m Int -> m ()

159composeScaling m =

160composeScaling m =

160 case m of

161 case m of

src/Streamly/Core.hs+2

@@ -1069,6 +1069,7 @@ newEmptySVar style = do

1069 AheadVar -> getAheadSVar style

1070

1071-- | Create a new SVar and enqueue one stream computation on it.

1072+{-# INLINABLE newStreamVar1 #-}

1072newStreamVar1 :: MonadAsync m => SVarStyle -> Stream m a -> m (SVar m a)

1073newStreamVar1 :: MonadAsync m => SVarStyle -> Stream m a -> m (SVar m a)

1073newStreamVar1 style m = do

1074newStreamVar1 style m = do

1074 sv <- newEmptySVar style

1075 sv <- newEmptySVar style

@@ -1083,6 +1084,7 @@ newStreamVar1 style m = do

1083 return sv

1084 return sv

1084

1085

1085-- | Create a new SVar and enqueue one stream computation on it.

1086-- | Create a new SVar and enqueue one stream computation on it.

1087+{-# INLINABLE newStreamVarAhead #-}

1086newStreamVarAhead :: MonadAsync m => Stream m a -> m (SVar m a)

1088newStreamVarAhead :: MonadAsync m => Stream m a -> m (SVar m a)

1087newStreamVarAhead m = do

1089newStreamVarAhead m = do

1088 sv <- newEmptySVar AheadVar

1090 sv <- newEmptySVar AheadVar