@@ -25,7 +25,7 @@ module Streamly.Internal.Data.Stream.Time
2525
2626 -- * Chunking
2727 , intervalsOf
28− , chunksOfTimeout
28+ , groupsOfTimeout
2929
3030 -- * Sampling
3131 , sampleIntervalEnd
@@ -239,13 +239,13 @@ intervalsOf n f xs =
239239-- is 100 ms.
240240--
241241-- >>> s = Stream.delayPost 0.3 $ Stream.fromList [1..1000]
242−-- >>> f = Stream.fold (Fold.drainMapM print) $ Stream.chunksOfTimeout 5 1 Fold.toList s
242+-- >>> f = Stream.fold (Fold.drainMapM print) $ Stream.groupsOfTimeout 5 1 Fold.toList s
243243--
244244-- /Pre-release/
245−{-# INLINE chunksOfTimeout #-}
246−chunksOfTimeout :: MonadAsync m
245+{-# INLINE groupsOfTimeout #-}
246+groupsOfTimeout :: MonadAsync m
247247 => Int -> Double -> Fold m a b -> Stream m a -> Stream m b
248−chunksOfTimeout n timeout f =
248+groupsOfTimeout n timeout f =
249249 fmap snd
250250 . classifySessionsBy
251251 0.1 False (const (return False)) timeout (Fold.take n f)