@@ -71,7 +71,7 @@ import qualified Streamly.Internal.Data.Array as Array
71 (fromStream, length, toStream)
71 (fromStream, length, toStream)
72import qualified Streamly.Data.Array.Unboxed.Mut as MA
72import qualified Streamly.Data.Array.Unboxed.Mut as MA
73import qualified Streamly.Internal.Data.Fold as Fold
73import qualified Streamly.Internal.Data.Fold as Fold
74− (head, last, toStream, toStreamRev)
74+ (one, last, toStream, toStreamRev)
75import qualified Streamly.Internal.Data.Parser as Parser
75import qualified Streamly.Internal.Data.Parser as Parser
76 (groupByRollingEither)
76 (groupByRollingEither)
77import qualified Streamly.Internal.Data.Stream.IsStream.Lift as Stream
77import qualified Streamly.Internal.Data.Stream.IsStream.Lift as Stream
@@ -132,7 +132,7 @@ sampleIntervalEnd n = Stream.catMaybes . Stream.intervalsOf n Fold.last
132-- | Like 'sampleInterval' but samples at the beginning of the time window.
132-- | Like 'sampleInterval' but samples at the beginning of the time window.
135−-- sampleIntervalStart n = Stream.catMaybes . Stream.intervalsOf n Fold.head
135+-- sampleIntervalStart n = Stream.catMaybes . Stream.intervalsOf n Fold.one
138-- /Pre-release/
138-- /Pre-release/
@@ -140,7 +140,7 @@ sampleIntervalEnd n = Stream.catMaybes . Stream.intervalsOf n Fold.last
140{-# INLINE sampleIntervalStart #-}
140{-# INLINE sampleIntervalStart #-}
141sampleIntervalStart :: (IsStream t, MonadAsync m, Functor (t m)) =>
141sampleIntervalStart :: (IsStream t, MonadAsync m, Functor (t m)) =>
142 Double -> t m a -> t m a
142 Double -> t m a -> t m a
143−sampleIntervalStart n = Stream.catMaybes . Stream.intervalsOf n Fold.head
143+sampleIntervalStart n = Stream.catMaybes . Stream.intervalsOf n Fold.one
145data BurstState t x =
145data BurstState t x =
146 BurstNone
146 BurstNone