4e34693 · streamly · git.iko.soy

core/src/Streamly/Internal/Data/Pipe.hs+4−7

compare with master

unifiedsplit

@@ -24,11 +24,10 @@

24module Streamly.Internal.Data.Pipe

25 (

26 -- * Pipe Type

27− Pipe

27+ module Streamly.Internal.Data.Pipe.Type

28

29 -- * Pipes

30 -- ** Mapping

31− , map

32 , mapM

31 , mapM

33

32

34 {-

33 {-

@@ -112,10 +111,8 @@ module Streamly.Internal.Data.Pipe

112 , groupsRollingBy

111 , groupsRollingBy

113 -}

112 -}

114

113

115− -- * Composing Pipes

114+

116− , tee

115+

117− , zipWith

118− , compose

119

116

120 {-

117 {-

121 -- * Distributing

118 -- * Distributing

@@ -244,7 +241,7 @@ import Prelude

244

241

245-- import Streamly.Data.Fold.Types (Fold(..))

242-- import Streamly.Data.Fold.Types (Fold(..))

246import Streamly.Internal.Data.Pipe.Type

243import Streamly.Internal.Data.Pipe.Type

247− (Pipe(..), PipeState(..), Step(..), zipWith, tee, map, compose)

244+

248-- import Streamly.Internal.Data.Array.Type (Array)

245-- import Streamly.Internal.Data.Array.Type (Array)

249-- import Streamly.Internal.Data.Ring (Ring)

246-- import Streamly.Internal.Data.Ring (Ring)

250-- import Streamly.Internal.Data.Stream (Stream)

247-- import Streamly.Internal.Data.Stream (Stream)

core/streamly-core.cabal+2−1

@@ -294,7 +294,6 @@ library

294 , Streamly.Internal.Data.Producer

295 , Streamly.Internal.Data.Parser.ParserK.Type

296 , Streamly.Internal.Data.Parser.ParserD.Type

297− , Streamly.Internal.Data.Pipe.Type

298

297

299 -- streamly-core-array-types

298 -- streamly-core-array-types

300 , Streamly.Internal.Data.Unbox

299 , Streamly.Internal.Data.Unbox

@@ -423,6 +422,8 @@ library

423

422

424 , Streamly.Internal.Data.Stream.StreamK.Type

423 , Streamly.Internal.Data.Stream.StreamK.Type

425

424

425+ , Streamly.Internal.Data.Pipe.Type

426+

426 , Streamly.Internal.Data.Unfold.Type

427 , Streamly.Internal.Data.Unfold.Type

427 , Streamly.Internal.Data.Unfold.Enumeration

428 , Streamly.Internal.Data.Unfold.Enumeration

428

429

src/Streamly/Internal/Data/Stream/IsStream/Transform.hs+1−1

@@ -221,7 +221,7 @@ import Data.Either (isLeft, isRight, fromLeft, fromRight)

221import Data.Kind (Type)

222import Data.Maybe (isJust, fromJust)

223import Streamly.Internal.Data.Fold (Fold (..))

224−import Streamly.Internal.Data.Pipe.Type (Pipe (..))

224+import Streamly.Internal.Data.Pipe (Pipe (..))

225import Streamly.Internal.Data.Stream.IsStream.Combinators

226 ( inspectMode, maxBuffer, maxThreads, rate, avgRate, minRate

227 , maxRate, constRate)