composewell/streamly
1
1
Fork 0
mirror of https://github.com/composewell/streamly.git synced 2024-10-05 23:37:43 +03:00
Code Issues Packages Projects Releases Wiki Activity

Fix up

Browse Source
This commit is contained in:
Ranjeet Kumar Ranjan 2023-07-24 21:09:28 +05:30
parent e26ded674f
commit 15510ac840
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/Streamly/Internal/Data/Stream/IsStream/Reduce.hs
View File

@ -41,7 +41,7 @@ module Streamly.Internal.Data.Stream.IsStream.Reduce {-# DEPRECATED "Please use
, chunksOf
, arraysOf
, intervalsOf
, groupsOfTimeout
, chunksOfTimeout
-- ** Splitting
-- | Streams can be sliced into segments in space or in time. We use the
@ -1025,13 +1025,13 @@ intervalsOf n f xs =
-- is 100 ms.
--
-- >>> s = Stream.delayPost 0.3 $ Stream.fromList [1..1000]
-- >>> f = Stream.mapM_ print $ Stream.groupsOfTimeout 5 1 Fold.toList s
-- >>> f = Stream.mapM_ print $ Stream.chunksOfTimeout 5 1 Fold.toList s
--
-- /Pre-release/
{-# INLINE groupsOfTimeout #-}
groupsOfTimeout :: (IsStream t, MonadAsync m, Functor (t m))
{-# INLINE chunksOfTimeout #-}
chunksOfTimeout :: (IsStream t, MonadAsync m, Functor (t m))
=> Int -> Double -> FL.Fold m a b -> t m a -> t m b
groupsOfTimeout n timeout f =
chunksOfTimeout n timeout f =
map snd
. classifySessionsBy
0.1 False (const (return False)) timeout (FL.take n f)