98393fc · streamly · git.iko.soy

git.iko.soy/streamly

move pipe module files to Internal

commit98393fc44a6d36c1da620c0d78076b01a896ee51 authorHarendra Kumar <harendra.kumar@gmail.com> dateWed 25 Sep 2019, 01:04 (7 years ago) parentfa8a5fd

8 files changed+16−16

compare with master

unifiedsplit

benchmark/Linear.hs+1−1 src/Streamly/Benchmark/Prelude.hs+1−1 src/Streamly/Internal/Data/Fold.hs+2−2 src/Streamly/Pipe.hs → src/Streamly/Internal/Data/Pipe.hs+5−5 src/Streamly/Pipe/Types.hs → src/Streamly/Internal/Data/Pipe/Types.hs+2−2 src/Streamly/Internal/Prelude.hs+1−1 src/Streamly/Streams/StreamD.hs+2−2 streamly.cabal+2−2

benchmark/Linear.hs+1−1

@@ -22,7 +22,7 @@ import Streamly

2222import qualified Streamly.Data.Fold as FL

2323import qualified Streamly.Internal.Data.Fold.Types as IFL

2424import qualified Streamly.Internal.Prelude as IP

25−--import qualified Streamly.Pipe as Pipe

25+--import qualified Streamly.Internal.Data.Pipe as Pipe

2626import qualified Streamly.Memory.Array as A

2727import qualified Streamly.Prelude as S

2828-- import qualified Streamly.Sink as Sink

src/Streamly/Benchmark/Prelude.hs+1−1

@@ -47,7 +47,7 @@ import qualified Streamly as S hiding (foldMapWith, runStream)

4747import qualified Streamly.Prelude as S

4848import qualified Streamly.Internal.Prelude as Internal

4949import qualified Streamly.Internal.Data.Unfold as UF

50−-- import qualified Streamly.Pipe as Pipe

50+-- import qualified Streamly.Internal.Data.Pipe as Pipe

5151

5252value, maxValue, value2 :: Int

5353#ifdef LINEAR_ASYNC

src/Streamly/Internal/Data/Fold.hs+2−2

@@ -248,11 +248,11 @@ import Prelude

248248import qualified Data.Map.Strict as Map

249249import qualified Prelude

250250

251−import Streamly.Pipe.Types (Pipe (..), PipeState(..))

251+import Streamly.Internal.Data.Pipe.Types (Pipe (..), PipeState(..))

252252import Streamly.Internal.Data.Fold.Types

253253import Streamly.Strict

254254

255−import qualified Streamly.Pipe.Types as Pipe

255+import qualified Streamly.Internal.Data.Pipe.Types as Pipe

256256

257257------------------------------------------------------------------------------

258258-- Transformations on fold inputs

src/Streamly/Pipe.hs → src/Streamly/Internal/Data/Pipe.hsrenamed+5−5

@@ -7,7 +7,7 @@

77{-# LANGUAGE ScopedTypeVariables #-}

99-- |

10−-- Module : Streamly.Pipe

10+-- Module : Streamly.Internal.Data.Pipe

1212-- License : BSD3

1313-- Maintainer : harendra.kumar@gmail.com

@@ -15,7 +15,7 @@

1515-- Portability : GHC

1616--

1717-- There are three fundamental types in streamly. They are streams

18−-- ("Streamly.Prelude"), pipes ("Streamly.Pipe") and folds ("Streamly.Data.Fold").

18+-- ("Streamly.Prelude"), pipes ("Streamly.Internal.Data.Pipe") and folds ("Streamly.Data.Fold").

1919-- Streams are sources or producers of values, multiple sources can be merged

2020-- into a single source but a source cannot be split into multiple stream

2121-- sources. Folds are sinks or consumers, a stream can be split and

@@ -27,9 +27,9 @@

2727-- fold to produce a fold, or multiple pipes can be merged or zipped into a

2828-- single pipe.

2929--

30−-- > import qualified Streamly.Pipe as P

30+-- > import qualified Streamly.Internal.Data.Pipe as P

3131

32−module Streamly.Pipe

32+module Streamly.Internal.Data.Pipe

3333 (

3434 -- * Pipe Type

3535 Pipe

@@ -252,7 +252,7 @@ import Prelude

252252

253253-- import Streamly (MonadAsync, parallel)

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

255−import Streamly.Pipe.Types

255+import Streamly.Internal.Data.Pipe.Types

256256 (Pipe(..), PipeState(..), Step(..), zipWith, tee, map, compose)

257257-- import Streamly.Internal.Memory.Array.Types (Array)

258258-- import Streamly.Memory.Ring (Ring)

src/Streamly/Pipe/Types.hs → src/Streamly/Internal/Data/Pipe/Types.hsrenamed+2−2

@@ -4,14 +4,14 @@

44#include "inline.hs"

66-- |

7−-- Module : Streamly.Pipe.Types

7+-- Module : Streamly.Internal.Data.Pipe.Types

99-- License : BSD3

1010-- Maintainer : harendra.kumar@gmail.com

1111-- Stability : experimental

1212-- Portability : GHC

1313

14−module Streamly.Pipe.Types

14+module Streamly.Internal.Data.Pipe.Types

1515 ( Step (..)

1616 , Pipe (..)

1717 , PipeState (..)

src/Streamly/Internal/Prelude.hs+1−1

@@ -415,7 +415,7 @@ import Streamly.Streams.Prelude

415415import Streamly.Streams.StreamD (fromStreamD, toStreamD)

416416import Streamly.Streams.StreamK (IsStream((|:), consM))

417417import Streamly.Streams.Serial (SerialT)

418−import Streamly.Pipe.Types (Pipe (..))

418+import Streamly.Internal.Data.Pipe.Types (Pipe (..))

419419import Streamly.Time.Units

420420 (AbsTime, MilliSecond64(..), addToAbsTime, diffAbsTime, toRelTime,

421421 toAbsTime)

src/Streamly/Streams/StreamD.hs+2−2

@@ -300,14 +300,14 @@ import qualified Control.Monad.Catch as MC

300300

301301import Streamly.Internal.Memory.Array.Types (Array(..))

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

303−import Streamly.Pipe.Types (Pipe(..), PipeState(..))

303+import Streamly.Internal.Data.Pipe.Types (Pipe(..), PipeState(..))

304304import Streamly.SVar (MonadAsync, defState, adaptState)

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

306306import Streamly.Strict (Tuple'(..))

307307

308308import Streamly.Streams.StreamD.Type

309309

310−import qualified Streamly.Pipe.Types as Pipe

310+import qualified Streamly.Internal.Data.Pipe.Types as Pipe

311311import qualified Streamly.Internal.Memory.Array.Types as A

312312import qualified Streamly.Memory.Ring as RB

313313import qualified Streamly.Streams.StreamK as K

streamly.cabal+2−2

@@ -282,8 +282,6 @@ library

282282 -- Folds

283283 , Streamly.Sink.Types

284284 , Streamly.Sink

285− , Streamly.Pipe.Types

286− , Streamly.Pipe

287285

288286 , Streamly.FileSystem.IOVec

289287 , Streamly.FileSystem.FDIO

@@ -313,6 +311,8 @@ library

313311 , Streamly.Internal.Data.Fold

314312 , Streamly.Internal.Data.Unfold.Types

315313 , Streamly.Internal.Data.Unfold

314+ , Streamly.Internal.Data.Pipe.Types

315+ , Streamly.Internal.Data.Pipe

316316 , Streamly.Internal.Data.List

317317 , Streamly.Internal.FileSystem.Handle

318318 , Streamly.Internal.FileSystem.File