98393fc · streamly · git.iko.soy

benchmark/Linear.hs+1−1

compare with master

unifiedsplit

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

22import qualified Streamly.Data.Fold as FL

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

24import qualified Streamly.Internal.Prelude as IP

25−--import qualified Streamly.Pipe as Pipe

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

26import qualified Streamly.Memory.Array as A

27import qualified Streamly.Prelude as S

28-- 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)

47import qualified Streamly.Prelude as S

48import qualified Streamly.Internal.Prelude as Internal

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

50−-- import qualified Streamly.Pipe as Pipe

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

51

52value, maxValue, value2 :: Int

53#ifdef LINEAR_ASYNC

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

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

248import qualified Data.Map.Strict as Map

249import qualified Prelude

250

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

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

252import Streamly.Internal.Data.Fold.Types

253import Streamly.Strict

254

255−import qualified Streamly.Pipe.Types as Pipe

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

256

257------------------------------------------------------------------------------

258-- Transformations on fold inputs

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

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

7{-# LANGUAGE ScopedTypeVariables #-}

8

9-- |

10−-- Module : Streamly.Pipe

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

12-- License : BSD3

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

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

15-- Portability : GHC

16--

17-- 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").

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

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

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

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

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

28-- single pipe.

29--

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

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

31

32−module Streamly.Pipe

32+module Streamly.Internal.Data.Pipe

33 (

34 -- * Pipe Type

35 Pipe

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

252

253-- import Streamly (MonadAsync, parallel)

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

255−import Streamly.Pipe.Types

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

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

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

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

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

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

4#include "inline.hs"

5

6-- |

7−-- Module : Streamly.Pipe.Types

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

9-- License : BSD3

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

11-- Stability : experimental

12-- Portability : GHC

13

14−module Streamly.Pipe.Types

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

15 ( Step (..)

16 , Pipe (..)

17 , PipeState (..)

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

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

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

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

417import Streamly.Streams.Serial (SerialT)

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

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

419import Streamly.Time.Units

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

421 toAbsTime)

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

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

300

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

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

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

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

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

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

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

307

308import Streamly.Streams.StreamD.Type

309

310−import qualified Streamly.Pipe.Types as Pipe

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

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

312import qualified Streamly.Memory.Ring as RB

313import qualified Streamly.Streams.StreamK as K

streamly.cabal+2−2

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

282 -- Folds

283 , Streamly.Sink.Types

284 , Streamly.Sink

285− , Streamly.Pipe.Types

286− , Streamly.Pipe

287

285

288 , Streamly.FileSystem.IOVec

286 , Streamly.FileSystem.IOVec

289 , Streamly.FileSystem.FDIO

287 , Streamly.FileSystem.FDIO

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

313 , Streamly.Internal.Data.Fold

311 , Streamly.Internal.Data.Fold

314 , Streamly.Internal.Data.Unfold.Types

312 , Streamly.Internal.Data.Unfold.Types

315 , Streamly.Internal.Data.Unfold

313 , Streamly.Internal.Data.Unfold

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

315+ , Streamly.Internal.Data.Pipe

316 , Streamly.Internal.Data.List

317 , Streamly.Internal.FileSystem.Handle

318 , Streamly.Internal.FileSystem.File