ilyakooo0/streamly
1
0
Fork 0
mirror of https://github.com/ilyakooo0/streamly.git synced 2024-10-26 09:59:48 +03:00
Code Issues Packages Projects Releases Wiki Activity

Rename sampleFromThen to strideFromThen

Browse Source
This commit is contained in:
Harendra Kumar 2022-12-07 18:04:56 +05:30
parent 90a88bc44d
commit 5cb0d4d289
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
core/src/Streamly/Internal/Data/Stream/Top.hs
View File

@ -13,7 +13,7 @@ module Streamly.Internal.Data.Stream.Top
-- * Transformation
-- ** Sampling
-- | Value agnostic filtering.
sampleFromThen
strideFromThen
-- ** Reordering
, sortBy
@ -78,18 +78,18 @@ import Prelude hiding (filter, zipWith, concatMap, concat)
-- XXX We can implement this using addition instead of "mod" to make it more
-- efficient.
--
-- | @sampleFromthen offset stride@ samples the element at @offset@ index and
-- | @strideFromthen offset stride@ takes the element at @offset@ index and
-- then every element at strides of @stride@.
--
-- >>> Stream.fold Fold.toList $ Stream.sampleFromThen 2 3 $ Stream.enumerateFromTo 0 10
-- >>> Stream.fold Fold.toList $ Stream.strideFromThen 2 3 $ Stream.enumerateFromTo 0 10
-- [2,5,8]
--
-- /Pre-release/
--
{-# INLINE sampleFromThen #-}
sampleFromThen :: Monad m => Int -> Int -> Stream m a -> Stream m a
sampleFromThen offset stride =
{-# INLINE strideFromThen #-}
strideFromThen :: Monad m => Int -> Int -> Stream m a -> Stream m a
strideFromThen offset stride =
Stream.with Stream.indexed Stream.filter
(\(i, _) -> i >= offset && (i - offset) `mod` stride == 0)