Import from lower level modules
commit678ee5e00d3358ba14b751a2c7e9aab21ba08999
authorHarendra Kumar <harendra@composewell.com>
dateWed 3 Feb 2021, 14:49 (6 years ago)
parent27d3575
src/Streamly/Internal/Data/Fold.hs−10
@@ -394,16 +394,6 @@ _Fold1 step = mkAccum step_ Nothing' toMaybe
394394-- Run Effects
395395------------------------------------------------------------------------------
396396
397−-- | A fold that drains all its input, running the effects and discarding the
398−-- results.
399−--
400−-- > drain = drainBy (const (return ()))
401−--
402−-- @since 0.7.0
403−{-# INLINABLE drain #-}
404−drain :: Monad m => Fold m a ()
405−drain = mkAccum_ (\_ _ -> ()) ()
406−
407397-- |
408398-- > drainBy f = lmapM f drain
409399-- > drainBy = FL.foldMapM (void . f)
src/Streamly/Internal/Data/Fold/Types.hs+11
@@ -186,6 +186,7 @@ module Streamly.Internal.Data.Fold.Types
186186 , simplify
187187
188188 -- * Basic Folds
189+ , drain
189190 , toList
190191
191192 -- * Generators
@@ -439,6 +440,16 @@ simplify (Fold2 step inject extract) c =
439440-- Basic Folds
440441------------------------------------------------------------------------------
441442
443+-- | A fold that drains all its input, running the effects and discarding the
444+-- results.
445+--
446+-- > drain = drainBy (const (return ()))
447+--
448+-- @since 0.7.0
449+{-# INLINABLE drain #-}
450+drain :: Monad m => Fold m a ()
451+drain = mkAccum_ (\_ _ -> ()) ()
452+
442453-- | Folds the input stream to a list.
443454--
444455-- /Warning!/ working on large lists accumulated as buffers in memory could be
src/Streamly/Internal/Data/Parser.hs+1−1
@@ -202,7 +202,7 @@ import Prelude
202202import Streamly.Internal.Data.Fold.Types (Fold(..))
203203import Streamly.Internal.Data.Parser.ParserK.Types (Parser)
204204
205−import qualified Streamly.Internal.Data.Fold as FL
205+import qualified Streamly.Internal.Data.Fold.Types as FL
206206import qualified Streamly.Internal.Data.Parser.ParserD as D
207207import qualified Streamly.Internal.Data.Parser.ParserK.Types as K
208208
src/Streamly/Internal/Data/Parser/ParserD/Types.hs+1−1
@@ -139,7 +139,7 @@ import Fusion.Plugin.Types (Fuse(..))
139139import Streamly.Internal.Data.Fold.Types (Fold(..), toList)
140140import Streamly.Internal.Data.Tuple.Strict (Tuple3'(..))
141141
142−import qualified Streamly.Internal.Data.Fold as FL
142+import qualified Streamly.Internal.Data.Fold.Types as FL
143143
144144import Prelude hiding (concatMap)
145145
src/Streamly/Internal/Data/Stream/StreamD/Nesting.hs+1−1
@@ -162,7 +162,7 @@ import Streamly.Internal.Data.Parser (ParseError(..))
162162import Streamly.Internal.Data.Unfold.Types (Unfold(..))
163163
164164import qualified Streamly.Internal.Data.Array.Foreign.Types as A
165−import qualified Streamly.Internal.Data.Fold as FL
165+import qualified Streamly.Internal.Data.Fold.Types as FL
166166import qualified Streamly.Internal.Data.Parser as PR
167167import qualified Streamly.Internal.Data.Parser.ParserD as PRD
168168import qualified Streamly.Internal.Ring.Foreign as RB
src/Streamly/Internal/Data/Stream/StreamD/Transform.hs+1−1
@@ -140,7 +140,7 @@ import Streamly.Internal.Data.Time.Units
140140 (TimeUnit64, toRelTime64, diffAbsTime64)
141141
142142import qualified Streamly.Internal.Data.Array.Foreign.Types as A
143−import qualified Streamly.Internal.Data.Fold as FL
143+import qualified Streamly.Internal.Data.Fold.Types as FL
144144import qualified Streamly.Internal.Data.IORef.Prim as Prim
145145import qualified Streamly.Internal.Data.Pipe.Types as Pipe
146146import qualified Streamly.Internal.Data.Stream.StreamK as K