@@ -320,6 +320,7 @@ module Streamly.Fold
320 -- , chunksOf
320 -- , chunksOf
321 , duplicate -- experimental
321 , duplicate -- experimental
323 -- * Windowed Classification
324 -- * Windowed Classification
324 -- | Split the stream into windows or chunks in space or time. Each window
325 -- | Split the stream into windows or chunks in space or time. Each window
325 -- can be associated with a key, all events associated with a particular
326 -- can be associated with a key, all events associated with a particular
@@ -333,13 +334,13 @@ module Streamly.Fold
333 -- ** Tumbling Windows
334 -- ** Tumbling Windows
334 -- | A new window starts after the previous window is finished.
335 -- | A new window starts after the previous window is finished.
335 -- , classifyChunksOf
336 -- , classifyChunksOf
336− , classifySessionsOf
337+ -- , classifySessionsOf
338 -- ** Keep Alive Windows
339 -- ** Keep Alive Windows
339 -- | The window size is extended if an event arrives within the specified
340 -- | The window size is extended if an event arrives within the specified
340 -- window size. This can represent sessions with idle or inactive timeout.
341 -- window size. This can represent sessions with idle or inactive timeout.
341 -- , classifyKeepAliveChunks
342 -- , classifyKeepAliveChunks
342− , classifyKeepAliveSessions
343+ -- , classifyKeepAliveSessions
345 -- ** Sliding Windows
346 -- ** Sliding Windows
@@ -351,6 +352,7 @@ module Streamly.Fold
351 -- ** Sliding Window Buffers
352 -- ** Sliding Window Buffers
352 -- , slidingChunkBuffer
353 -- , slidingChunkBuffer
353 -- , slidingSessionBuffer
354 -- , slidingSessionBuffer
@@ -2636,14 +2638,14 @@ classifySessionsBy tick timeout reset (Fold step initial extract) str =
2636-- only if no event is received within the specified session window size.
2638-- only if no event is received within the specified session window size.
2638-- @since 0.7.0
2640-- @since 0.7.0
2639−{-# INLINABLE classifyKeepAliveSessions #-}
2641+{-# INLINABLE _classifyKeepAliveSessions #-}
2640−classifyKeepAliveSessions
2642+_classifyKeepAliveSessions
2641 :: (IsStream t, MonadAsync m, Ord k)
2643 :: (IsStream t, MonadAsync m, Ord k)
2642 => Double -- ^ session inactive timeout
2644 => Double -- ^ session inactive timeout
2643 -> Fold m a b -- ^ Fold to be applied to session payload data
2645 -> Fold m a b -- ^ Fold to be applied to session payload data
2644 -> t m (k, a, Bool, AbsTime) -- ^ session key, data, close flag, timestamp
2646 -> t m (k, a, Bool, AbsTime) -- ^ session key, data, close flag, timestamp
2645 -> t m (k, b)
2647 -> t m (k, b)
2646−classifyKeepAliveSessions timeout = classifySessionsBy 1 timeout True
2648+_classifyKeepAliveSessions timeout = classifySessionsBy 1 timeout True
2648------------------------------------------------------------------------------
2650------------------------------------------------------------------------------
2649-- Keyed tumbling windows
2651-- Keyed tumbling windows
@@ -2685,11 +2687,11 @@ classifyChunksOf wsize = classifyChunksBy wsize False
2685-- the timestamps with a clock resolution of 1 second.
2687-- the timestamps with a clock resolution of 1 second.
2687-- @since 0.7.0
2689-- @since 0.7.0
2688−{-# INLINABLE classifySessionsOf #-}
2690+{-# INLINABLE _classifySessionsOf #-}
2689−classifySessionsOf
2691+_classifySessionsOf
2690 :: (IsStream t, MonadAsync m, Ord k)
2692 :: (IsStream t, MonadAsync m, Ord k)
2691 => Double -- ^ time window size
2693 => Double -- ^ time window size
2692 -> Fold m a b -- ^ Fold to be applied to window events
2694 -> Fold m a b -- ^ Fold to be applied to window events
2693 -> t m (k, a, Bool, AbsTime) -- ^ window key, data, close flag, timestamp
2695 -> t m (k, a, Bool, AbsTime) -- ^ window key, data, close flag, timestamp
2694 -> t m (k, b)
2696 -> t m (k, b)
2695−classifySessionsOf interval = classifySessionsBy 1 interval False
2697+_classifySessionsOf interval = classifySessionsBy 1 interval False