@@ -1001,7 +1001,8 @@ intervalsOf n f xs =
1002-- | Like 'chunksOf' but if the chunk is not completed within the specified
1002-- | Like 'chunksOf' but if the chunk is not completed within the specified
1003-- time interval then emit whatever we have collected till now. The chunk
1003-- time interval then emit whatever we have collected till now. The chunk
1004−-- timeout is reset whenever a chunk is emitted.
1004+-- timeout is reset whenever a chunk is emitted. The granularity of the clock
1006-- >>> s = Stream.delayPost 0.3 $ Stream.fromList [1..1000]
1007-- >>> s = Stream.delayPost 0.3 $ Stream.fromList [1..1000]
1007-- >>> f = Stream.mapM_ print $ Stream.chunksOfTimeout 5 1 Fold.toList s
1008-- >>> f = Stream.mapM_ print $ Stream.chunksOfTimeout 5 1 Fold.toList s
@@ -1013,7 +1014,7 @@ chunksOfTimeout :: (IsStream t, MonadAsync m, Functor (t m))
1013chunksOfTimeout n timeout f =
1014chunksOfTimeout n timeout f =
1015 . classifySessionsBy
1016 . classifySessionsBy
1016− timeout False (const (return False)) timeout (FL.take n f)
1017+ 0.1 False (const (return False)) timeout (FL.take n f)
1017 . Transform.timestamped
1018 . Transform.timestamped
1018 . map ((),)
1019 . map ((),)