@@ -109,10 +109,10 @@ module Streamly.Internal.Data.Stream.IsStream.Transform {-# DEPRECATED "Please u
109109 -- Element agnostic (Opposite of sampling)
110110 , intersperse
111111 , intersperseM -- XXX naming
112− , intersperseBySpan
112+ , intersperseMWith
113113
114− , intersperseSuffix
115− , intersperseSuffixBySpan
114+ , intersperseMSuffix
115+ , intersperseMSuffixWith
116116 , interjectSuffix
117117
118118 -- , interspersePrefix
@@ -121,9 +121,9 @@ module Streamly.Internal.Data.Stream.IsStream.Transform {-# DEPRECATED "Please u
121121 -- * Inserting Side Effects/Time
122122 , intersperseM_ -- XXX naming
123123 , delay
124− , intersperseSuffix_
124+ , intersperseMSuffix_
125125 , delayPost
126− , interspersePrefix_
126+ , intersperseMPrefix_
127127 , delayPre
128128
129129 -- * Element Aware Insertion
@@ -261,8 +261,8 @@ import qualified Streamly.Internal.Data.Stream.StreamD as D
261261 , scanMany, postscanOnce, scanlx', scanlM', scanl', postscanl', prescanl'
262262 , prescanlM', scanl1M', scanl1', filter, filterM, uniq, deleteBy, takeWhileM
263263 , dropWhile, dropWhileM, insertBy, intersperse
264− , intersperseM_, intersperseSuffix, intersperseSuffix_
265− , intersperseSuffixBySpan, indexed, indexedR, rollingMap, rollingMapM
264+ , intersperseM_, intersperseMSuffix, intersperseMSuffix_
265+ , intersperseMSuffixWith, indexed, indexedR, rollingMap, rollingMapM
266266 , rollingMap2, mapMaybe, mapMaybeM)
267267import qualified Streamly.Internal.Data.Stream.StreamK.Type as K
268268 (foldrS, foldrSShared, mapMWith)
@@ -610,7 +610,7 @@ trace f = mapM (\x -> void (f x) >> return x)
610610--
611611-- @
612612--
613−-- Same as 'interspersePrefix_' but always serial.
613+-- Same as 'intersperseMPrefix_' but always serial.
614614--
615615-- See also: 'trace'
616616--
@@ -1165,60 +1165,60 @@ intersperseM_ m = fromStreamD . D.intersperseM_ m . toStreamD
11651165-- elements.
11661166--
11671167-- @
1168−-- > Stream.toList $ Stream.intersperseBySpan 2 (return ',') $ Stream.fromList "hello"
1168+-- > Stream.toList $ Stream.intersperseMWith 2 (return ',') $ Stream.fromList "hello"
11691169-- "he,ll,o"
11701170--
11711171-- @
11721172--
11731173-- /Unimplemented/
1174−{-# INLINE intersperseBySpan #-}
1175−intersperseBySpan :: -- IsStream t =>
1174+{-# INLINE intersperseMWith #-}
1175+intersperseMWith :: -- IsStream t =>
11761176 Int -> m a -> t m a -> t m a
1177−intersperseBySpan _n _f _xs = undefined
1177+intersperseMWith _n _f _xs = undefined
11781178
11791179-- | Insert an effect and its output after consuming an element of a stream.
11801180--
1181−-- >>> Stream.toList $ Stream.trace putChar $ intersperseSuffix (putChar '.' >> return ',') $ Stream.fromList "hello"
1181+-- >>> Stream.toList $ Stream.trace putChar $ intersperseMSuffix (putChar '.' >> return ',') $ Stream.fromList "hello"
11821182-- h.,e.,l.,l.,o.,"h,e,l,l,o,"
11831183--
11841184-- /Pre-release/
1185−{-# INLINE intersperseSuffix #-}
1186−intersperseSuffix :: (IsStream t, Monad m) => m a -> t m a -> t m a
1187−intersperseSuffix m = fromStreamD . D.intersperseSuffix m . toStreamD
1185+{-# INLINE intersperseMSuffix #-}
1186+intersperseMSuffix :: (IsStream t, Monad m) => m a -> t m a -> t m a
1187+intersperseMSuffix m = fromStreamD . D.intersperseMSuffix m . toStreamD
11881188
11891189-- | Insert a side effect after consuming an element of a stream.
11901190--
11911191-- @
1192−-- >>> Stream.mapM_ putChar $ Stream.intersperseSuffix_ (threadDelay 1000000) $ Stream.fromList "hello"
1192+-- >>> Stream.mapM_ putChar $ Stream.intersperseMSuffix_ (threadDelay 1000000) $ Stream.fromList "hello"
11931193-- hello
11941194--
11951195-- @
11961196--
11971197-- /Pre-release/
11981198--
1199−{-# INLINE intersperseSuffix_ #-}
1200−intersperseSuffix_ :: (IsStream t, Monad m) => m b -> t m a -> t m a
1201−intersperseSuffix_ m = fromStreamD . D.intersperseSuffix_ m . toStreamD
1199+{-# INLINE intersperseMSuffix_ #-}
1200+intersperseMSuffix_ :: (IsStream t, Monad m) => m b -> t m a -> t m a
1201+intersperseMSuffix_ m = fromStreamD . D.intersperseMSuffix_ m . toStreamD
12021202
12031203-- XXX Use an offset argument, like tapOffsetEvery
12041204--
1205−-- | Like 'intersperseSuffix' but intersperses an effectful action into the
1205+-- | Like 'intersperseMSuffix' but intersperses an effectful action into the
12061206-- input stream after every @n@ elements and after the last element.
12071207--
1208−-- >>> Stream.toList $ Stream.intersperseSuffixBySpan 2 (return ',') $ Stream.fromList "hello"
1208+-- >>> Stream.toList $ Stream.intersperseMSuffixWith 2 (return ',') $ Stream.fromList "hello"
12091209-- "he,ll,o,"
12101210--
12111211-- /Pre-release/
12121212--
1213−{-# INLINE intersperseSuffixBySpan #-}
1214−intersperseSuffixBySpan :: (IsStream t, Monad m)
1213+{-# INLINE intersperseMSuffixWith #-}
1214+intersperseMSuffixWith :: (IsStream t, Monad m)
12151215 => Int -> m a -> t m a -> t m a
1216−intersperseSuffixBySpan n eff =
1217− fromStreamD . D.intersperseSuffixBySpan n eff . toStreamD
1216+intersperseMSuffixWith n eff =
1217+ fromStreamD . D.intersperseMSuffixWith n eff . toStreamD
12181218
12191219-- | Insert a side effect before consuming an element of a stream.
12201220--
1221−-- >>> Stream.toList $ Stream.trace putChar $ Stream.interspersePrefix_ (putChar '.' >> return ',') $ Stream.fromList "hello"
1221+-- >>> Stream.toList $ Stream.trace putChar $ Stream.intersperseMPrefix_ (putChar '.' >> return ',') $ Stream.fromList "hello"
12221222-- .h.e.l.l.o"hello"
12231223--
12241224-- Same as 'trace_' but may be concurrent.
@@ -1227,9 +1227,9 @@ intersperseSuffixBySpan n eff =
12271227--
12281228-- /Pre-release/
12291229--
1230−{-# INLINE interspersePrefix_ #-}
1231−interspersePrefix_ :: (IsStream t, MonadAsync m) => m b -> t m a -> t m a
1232−interspersePrefix_ m = mapM (\x -> void m >> return x)
1230+{-# INLINE intersperseMPrefix_ #-}
1231+intersperseMPrefix_ :: (IsStream t, MonadAsync m) => m b -> t m a -> t m a
1232+intersperseMPrefix_ m = mapM (\x -> void m >> return x)
12331233
12341234------------------------------------------------------------------------------
12351235-- Inserting Time
@@ -1265,7 +1265,7 @@ delay n = intersperseM_ $ liftIO $ threadDelay $ round $ n * 1000000
12651265--
12661266{-# INLINE delayPost #-}
12671267delayPost :: (IsStream t, MonadIO m) => Double -> t m a -> t m a
1268−delayPost n = intersperseSuffix_ $ liftIO $ threadDelay $ round $ n * 1000000
1268+delayPost n = intersperseMSuffix_ $ liftIO $ threadDelay $ round $ n * 1000000
12691269
12701270-- Note: delay must be serial, that's why 'trace_' is used.
12711271--