@@ -25,7 +25,7 @@ module Streamly.Internal.Data.Stream.Time
26 -- * Chunking
26 -- * Chunking
27 , intervalsOf
27 , intervalsOf
28− , chunksOfTimeout
28+ , groupsOfTimeout
30 -- * Sampling
30 -- * Sampling
31 , sampleIntervalEnd
31 , sampleIntervalEnd
@@ -239,13 +239,13 @@ intervalsOf n f xs =
239-- is 100 ms.
239-- is 100 ms.
241-- >>> s = Stream.delayPost 0.3 $ Stream.fromList [1..1000]
241-- >>> 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
244-- /Pre-release/
244-- /Pre-release/
245−{-# INLINE chunksOfTimeout #-}
245+{-# INLINE groupsOfTimeout #-}
246−chunksOfTimeout :: MonadAsync m
246+groupsOfTimeout :: MonadAsync m
247 => Int -> Double -> Fold m a b -> Stream m a -> Stream m b
247 => Int -> Double -> Fold m a b -> Stream m a -> Stream m b
248−chunksOfTimeout n timeout f =
248+groupsOfTimeout n timeout f =
250 . classifySessionsBy
250 . classifySessionsBy
251 0.1 False (const (return False)) timeout (Fold.take n f)
251 0.1 False (const (return False)) timeout (Fold.take n f)