@@ -1001,7 +1001,8 @@ intervalsOf n f xs =
10011001--
10021002-- | Like 'chunksOf' but if the chunk is not completed within the specified
10031003-- 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
1005+-- is 100 ms.
10051006--
10061007-- >>> s = Stream.delayPost 0.3 $ Stream.fromList [1..1000]
10071008-- >>> f = Stream.mapM_ print $ Stream.chunksOfTimeout 5 1 Fold.toList s
@@ -1013,7 +1014,7 @@ chunksOfTimeout :: (IsStream t, MonadAsync m, Functor (t m))
10131014chunksOfTimeout n timeout f =
10141015 map snd
10151016 . classifySessionsBy
1016− timeout False (const (return False)) timeout (FL.take n f)
1017+ 0.1 False (const (return False)) timeout (FL.take n f)
10171018 . Transform.timestamped
10181019 . map ((),)
10191020