@@ -82,20 +82,20 @@ module Streamly.Internal.Data.Stream.IsStream.Transform
82 -- | Produce a subset of the stream trimmed at ends.
82 -- | Produce a subset of the stream trimmed at ends.
85− , takeByTime -- takeInterval
85+ , takeInterval
86− , takeEnd
86+ , takeLast
87− , takeEndInterval
87+ , takeLastInterval
88 , takeWhile
88 , takeWhile
89 , takeWhileM
89 , takeWhileM
90− , takeWhileEnd
90+ , takeWhileLast
91 , takeWhileAround
91 , takeWhileAround
93− , dropByTime -- dropInterval
93+ , dropInterval
94− , dropEnd
94+ , dropLast
95− , dropEndInterval
95+ , dropLastInterval
96 , dropWhile
96 , dropWhile
97 , dropWhileM
97 , dropWhileM
98− , dropWhileEnd
98+ , dropWhileLast
99 , dropWhileAround
99 , dropWhileAround
101 -- * Inserting Elements
101 -- * Inserting Elements
@@ -931,27 +931,27 @@ takeWhileM p m = fromStreamD $ D.takeWhileM p $ toStreamD m
932-- See the lastN fold for impl hints. Use a Data.Array based ring buffer.
932-- See the lastN fold for impl hints. Use a Data.Array based ring buffer.
934−-- takeEnd n = Stream.concatM . fmap Array.toStream . fold Fold.lastN
934+-- takeLast n = Stream.concatM . fmap Array.toStream . fold Fold.lastN
936-- | Take @n@ elements at the end of the stream.
936-- | Take @n@ elements at the end of the stream.
938-- O(n) space, where n is the number elements taken.
938-- O(n) space, where n is the number elements taken.
940-- /Unimplemented/
940-- /Unimplemented/
941−{-# INLINE takeEnd #-}
941+{-# INLINE takeLast #-}
942−takeEnd :: -- (IsStream t, Monad m) =>
942+takeLast :: -- (IsStream t, Monad m) =>
943 Int -> t m a -> t m a
943 Int -> t m a -> t m a
944−takeEnd = undefined -- fromStreamD $ D.takeEnd n $ toStreamD m
944+takeLast = undefined -- fromStreamD $ D.takeLast n $ toStreamD m
946-- | Take time interval @i@ seconds at the end of the stream.
946-- | Take time interval @i@ seconds at the end of the stream.
948-- O(n) space, where n is the number elements taken.
948-- O(n) space, where n is the number elements taken.
950-- /Unimplemented/
950-- /Unimplemented/
951−{-# INLINE takeEndInterval #-}
951+{-# INLINE takeLastInterval #-}
952−takeEndInterval :: -- (IsStream t, Monad m) =>
952+takeLastInterval :: -- (IsStream t, Monad m) =>
953 Double -> t m a -> t m a
953 Double -> t m a -> t m a
954−takeEndInterval = undefined -- fromStreamD $ D.takeEnd n $ toStreamD m
954+takeLastInterval = undefined -- fromStreamD $ D.takeLast n $ toStreamD m
956-- | Take all consecutive elements at the end of the stream for which the
956-- | Take all consecutive elements at the end of the stream for which the
957-- predicate is true.
957-- predicate is true.
@@ -959,12 +959,12 @@ takeEndInterval = undefined -- fromStreamD $ D.takeEnd n $ toStreamD m
959-- O(n) space, where n is the number elements taken.
959-- O(n) space, where n is the number elements taken.
961-- /Unimplemented/
961-- /Unimplemented/
962−{-# INLINE takeWhileEnd #-}
962+{-# INLINE takeWhileLast #-}
963−takeWhileEnd :: -- (IsStream t, Monad m) =>
963+takeWhileLast :: -- (IsStream t, Monad m) =>
964 (a -> Bool) -> t m a -> t m a
964 (a -> Bool) -> t m a -> t m a
965−takeWhileEnd = undefined -- fromStreamD $ D.takeWhileEnd n $ toStreamD m
965+takeWhileLast = undefined -- fromStreamD $ D.takeWhileLast n $ toStreamD m
967−-- | Like 'takeWhile' and 'takeWhileEnd' combined.
967+-- | Like 'takeWhile' and 'takeWhileLast' combined.
969-- O(n) space, where n is the number elements taken from the end.
969-- O(n) space, where n is the number elements taken from the end.
@@ -974,7 +974,7 @@ takeWhileAround :: -- (IsStream t, Monad m) =>
974 (a -> Bool) -> t m a -> t m a
974 (a -> Bool) -> t m a -> t m a
975takeWhileAround = undefined -- fromStreamD $ D.takeWhileAround n $ toStreamD m
975takeWhileAround = undefined -- fromStreamD $ D.takeWhileAround n $ toStreamD m
977−-- | @takeByTime duration@ yields stream elements upto specified time
977+-- | @takeInterval duration@ yields stream elements upto specified time
978-- @duration@. The duration starts when the stream is evaluated for the first
978-- @duration@. The duration starts when the stream is evaluated for the first
979-- time, before the first element is yielded. The time duration is checked
979-- time, before the first element is yielded. The time duration is checked
980-- before generating each element, if the duration has expired the stream
980-- before generating each element, if the duration has expired the stream
@@ -990,9 +990,9 @@ takeWhileAround = undefined -- fromStreamD $ D.takeWhileAround n $ toStreamD m
991-- /Pre-release/
991-- /Pre-release/
993−{-# INLINE takeByTime #-}
993+{-# INLINE takeInterval #-}
994−takeByTime ::(MonadIO m, IsStream t, TimeUnit64 d) => d -> t m a -> t m a
994+takeInterval ::(MonadIO m, IsStream t, TimeUnit64 d) => d -> t m a -> t m a
995−takeByTime d = fromStreamD . D.takeByTime d . toStreamD
995+takeInterval d = fromStreamD . D.takeByTime d . toStreamD
997-- | Drop elements in the stream as long as the predicate succeeds and then
997-- | Drop elements in the stream as long as the predicate succeeds and then
998-- take the rest of the stream.
998-- take the rest of the stream.
@@ -1009,7 +1009,7 @@ dropWhile p m = fromStreamS $ S.dropWhile p $ toStreamS m
1009dropWhileM :: (IsStream t, Monad m) => (a -> m Bool) -> t m a -> t m a
1009dropWhileM :: (IsStream t, Monad m) => (a -> m Bool) -> t m a -> t m a
1010dropWhileM p m = fromStreamD $ D.dropWhileM p $ toStreamD m
1010dropWhileM p m = fromStreamD $ D.dropWhileM p $ toStreamD m
1012−-- | @dropByTime duration@ drops stream elements until specified @duration@ has
1012+-- | @dropInterval duration@ drops stream elements until specified @duration@ has
1013-- passed. The duration begins when the stream is evaluated for the first
1013-- passed. The duration begins when the stream is evaluated for the first
1014-- time. The time duration is checked /after/ generating a stream element, the
1014-- time. The time duration is checked /after/ generating a stream element, the
1015-- element is yielded if the duration has expired otherwise it is dropped.
1015-- element is yielded if the duration has expired otherwise it is dropped.
@@ -1023,29 +1023,29 @@ dropWhileM p m = fromStreamD $ D.dropWhileM p $ toStreamD m
1024-- /Pre-release/
1024-- /Pre-release/
1026−{-# INLINE dropByTime #-}
1026+{-# INLINE dropInterval #-}
1027−dropByTime ::(MonadIO m, IsStream t, TimeUnit64 d) => d -> t m a -> t m a
1027+dropInterval ::(MonadIO m, IsStream t, TimeUnit64 d) => d -> t m a -> t m a
1028−dropByTime d = fromStreamD . D.dropByTime d . toStreamD
1028+dropInterval d = fromStreamD . D.dropByTime d . toStreamD
1030-- | Drop @n@ elements at the end of the stream.
1030-- | Drop @n@ elements at the end of the stream.
1032-- O(n) space, where n is the number elements dropped.
1032-- O(n) space, where n is the number elements dropped.
1034-- /Unimplemented/
1034-- /Unimplemented/
1035−{-# INLINE dropEnd #-}
1035+{-# INLINE dropLast #-}
1036−dropEnd :: -- (IsStream t, Monad m) =>
1036+dropLast :: -- (IsStream t, Monad m) =>
1037 Int -> t m a -> t m a
1037 Int -> t m a -> t m a
1038−dropEnd = undefined -- fromStreamD $ D.dropEnd n $ toStreamD m
1038+dropLast = undefined -- fromStreamD $ D.dropLast n $ toStreamD m
1040-- | Drop time interval @i@ seconds at the end of the stream.
1040-- | Drop time interval @i@ seconds at the end of the stream.
1042-- O(n) space, where n is the number elements dropped.
1042-- O(n) space, where n is the number elements dropped.
1044-- /Unimplemented/
1044-- /Unimplemented/
1045−{-# INLINE dropEndInterval #-}
1045+{-# INLINE dropLastInterval #-}
1046−dropEndInterval :: -- (IsStream t, Monad m) =>
1046+dropLastInterval :: -- (IsStream t, Monad m) =>
1047 Int -> t m a -> t m a
1047 Int -> t m a -> t m a
1048−dropEndInterval = undefined
1048+dropLastInterval = undefined
1050-- | Drop all consecutive elements at the end of the stream for which the
1050-- | Drop all consecutive elements at the end of the stream for which the
1051-- predicate is true.
1051-- predicate is true.
@@ -1053,12 +1053,12 @@ dropEndInterval = undefined
1053-- O(n) space, where n is the number elements dropped.
1053-- O(n) space, where n is the number elements dropped.
1055-- /Unimplemented/
1055-- /Unimplemented/
1056−{-# INLINE dropWhileEnd #-}
1056+{-# INLINE dropWhileLast #-}
1057−dropWhileEnd :: -- (IsStream t, Monad m) =>
1057+dropWhileLast :: -- (IsStream t, Monad m) =>
1058 (a -> Bool) -> t m a -> t m a
1058 (a -> Bool) -> t m a -> t m a
1059−dropWhileEnd = undefined -- fromStreamD $ D.dropWhileEnd n $ toStreamD m
1059+dropWhileLast = undefined -- fromStreamD $ D.dropWhileLast n $ toStreamD m
1061−-- | Like 'dropWhile' and 'dropWhileEnd' combined.
1061+-- | Like 'dropWhile' and 'dropWhileLast' combined.
1063-- O(n) space, where n is the number elements dropped from the end.
1063-- O(n) space, where n is the number elements dropped from the end.