678ee5e · streamly · git.iko.soy

src/Streamly/Internal/Data/Fold.hs−10

compare with master

unifiedsplit

@@ -394,16 +394,6 @@ _Fold1 step = mkAccum step_ Nothing' toMaybe

394-- Run Effects

395------------------------------------------------------------------------------

396

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−

407-- |

397-- |

408-- > drainBy f = lmapM f drain

398-- > drainBy f = lmapM f drain

409-- > drainBy = FL.foldMapM (void . f)

399-- > drainBy = FL.foldMapM (void . f)

src/Streamly/Internal/Data/Fold/Types.hs+11

@@ -186,6 +186,7 @@ module Streamly.Internal.Data.Fold.Types

186 , simplify

187

188 -- * Basic Folds

189+ , drain

189 , toList

190 , toList

190

191

191 -- * Generators

192 -- * Generators

@@ -439,6 +440,16 @@ simplify (Fold2 step inject extract) c =

439-- Basic Folds

440-- Basic Folds

440------------------------------------------------------------------------------

441------------------------------------------------------------------------------

441

442

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+

442-- | Folds the input stream to a list.

453-- | Folds the input stream to a list.

443--

454--

444-- /Warning!/ working on large lists accumulated as buffers in memory could be

455-- /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

202import Streamly.Internal.Data.Fold.Types (Fold(..))

203import Streamly.Internal.Data.Parser.ParserK.Types (Parser)

204

205−import qualified Streamly.Internal.Data.Fold as FL

205+import qualified Streamly.Internal.Data.Fold.Types as FL

206import qualified Streamly.Internal.Data.Parser.ParserD as D

207import qualified Streamly.Internal.Data.Parser.ParserK.Types as K

208

src/Streamly/Internal/Data/Parser/ParserD/Types.hs+1−1

@@ -139,7 +139,7 @@ import Fusion.Plugin.Types (Fuse(..))

139import Streamly.Internal.Data.Fold.Types (Fold(..), toList)

140import Streamly.Internal.Data.Tuple.Strict (Tuple3'(..))

141

142−import qualified Streamly.Internal.Data.Fold as FL

142+import qualified Streamly.Internal.Data.Fold.Types as FL

143

144import Prelude hiding (concatMap)

145

src/Streamly/Internal/Data/Stream/StreamD/Nesting.hs+1−1

@@ -162,7 +162,7 @@ import Streamly.Internal.Data.Parser (ParseError(..))

162import Streamly.Internal.Data.Unfold.Types (Unfold(..))

163

164import 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

166import qualified Streamly.Internal.Data.Parser as PR

167import qualified Streamly.Internal.Data.Parser.ParserD as PRD

168import 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

140 (TimeUnit64, toRelTime64, diffAbsTime64)

141

142import 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

144import qualified Streamly.Internal.Data.IORef.Prim as Prim

145import qualified Streamly.Internal.Data.Pipe.Types as Pipe

146import qualified Streamly.Internal.Data.Stream.StreamK as K