631cc24 · streamly · git.iko.soy

git.iko.soy/streamly

move file SVar.hs to Internal/Data

commit631cc24fec3f208cb52e5c1397999a8dd4357542 authorHarendra Kumar <harendra.kumar@gmail.com> dateWed 25 Sep 2019, 11:00 (7 years ago) parente2baec7

20 files changed+24−24

compare with master

unifiedsplit

benchmark/NanoBenchmarks.hs+1−1

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

77{-# LANGUAGE ScopedTypeVariables #-}

99import Streamly (SerialT)

10−import Streamly.SVar (MonadAsync)

10+import Streamly.Internal.Data.SVar (MonadAsync)

1111

1212import qualified Streamly.Memory.Array as A

1313import qualified Streamly.FileSystem.Handle as FH

benchmark/StreamDKOps.hs+1−1

@@ -21,7 +21,7 @@ import qualified Prelude as P

2121

2222import qualified Streamly.Streams.StreamDK as S

2323-- import qualified Streamly.Streams.Prelude as SP

24−-- import qualified Streamly.SVar as S

24+-- import qualified Streamly.Internal.Data.SVar as S

2525

2626value, value2, value3, value16, maxValue :: Int

2727value = 100000

benchmark/StreamKOps.hs+1−1

@@ -21,7 +21,7 @@ import qualified Data.List as List

2121

2222import qualified Streamly.Streams.StreamK as S

2323import qualified Streamly.Streams.Prelude as SP

24−import qualified Streamly.SVar as S

24+import qualified Streamly.Internal.Data.SVar as S

2525

2626value, value2, value3, value16, maxValue :: Int

2727value = 100000

src/Streamly.hs+1−1

@@ -211,7 +211,7 @@ module Streamly

211211where

212212

213213import Data.Semigroup (Semigroup(..))

214−import Streamly.SVar (MonadAsync, Rate(..))

214+import Streamly.Internal.Data.SVar (MonadAsync, Rate(..))

215215import Streamly.Streams.Ahead

216216import Streamly.Streams.Async

217217import Streamly.Streams.Combinators

src/Streamly/Internal/Data/Fold/Types.hs+1−1

@@ -43,7 +43,7 @@ import Data.Maybe (isJust, fromJust)

4343import Data.Semigroup (Semigroup(..))

4444#endif

4545import Streamly.Strict (Tuple'(..), Tuple3'(..), Either'(..))

46−import Streamly.SVar (MonadAsync)

46+import Streamly.Internal.Data.SVar (MonadAsync)

4747

4848------------------------------------------------------------------------------

4949-- Monadic left folds

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

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

1313{-# LANGUAGE UnboxedTuples #-}

1414

1515-- |

16−-- Module : Streamly.SVar

16+-- Module : Streamly.Internal.Data.SVar

1818--

1919-- License : BSD3

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

2121-- Stability : experimental

2222-- Portability : GHC

2323

24−module Streamly.SVar

24+module Streamly.Internal.Data.SVar

2525 (

2626 MonadAsync

2727 , SVarStyle (..)

src/Streamly/Internal/FileSystem/File.hs+1−1

@@ -118,7 +118,7 @@ import qualified System.IO as SIO

118118import Streamly.Internal.Memory.Array.Types (Array(..), defaultChunkSize)

119119import Streamly.Streams.Serial (SerialT)

120120import Streamly.Streams.StreamK.Type (IsStream)

121−import Streamly.SVar (MonadAsync)

121+import Streamly.Internal.Data.SVar (MonadAsync)

122122-- import Streamly.Data.Fold (Fold)

123123-- import Streamly.String (encodeUtf8, decodeUtf8, foldLines)

124124

src/Streamly/Internal/Memory/Array/Types.hs+1−1

@@ -113,7 +113,7 @@ import GHC.Ptr (Ptr(..))

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

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

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

116−import Streamly.SVar (adaptState)

116+import Streamly.Internal.Data.SVar (adaptState)

117117

118118#if !defined(mingw32_HOST_OS)

119119import Streamly.FileSystem.FDIO (IOVec(..))

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

@@ -407,7 +407,7 @@ import Streamly.Internal.Data.Fold.Types (Fold (..))

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

408408import Streamly.Internal.Memory.Array.Types (Array, writeNUnsafe)

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

410−import Streamly.SVar (MonadAsync, defState)

410+import Streamly.Internal.Data.SVar (MonadAsync, defState)

411411import Streamly.Streams.Async (mkAsync')

412412import Streamly.Streams.Combinators (maxYields)

413413import Streamly.Streams.Prelude

src/Streamly/Streams/Ahead.hs+1−1

@@ -48,7 +48,7 @@ import qualified Data.Heap as H

4848

4949import Streamly.Streams.SVar (fromSVar)

5050import Streamly.Streams.Serial (map)

51−import Streamly.SVar

51+import Streamly.Internal.Data.SVar

5252import Streamly.Streams.StreamK

5353 (IsStream(..), Stream, mkStream, foldStream, foldStreamShared,

5454 foldStreamSVar)

src/Streamly/Streams/Async.hs+1−1

@@ -59,7 +59,7 @@ import qualified Data.Set as S

5959import Streamly.Internal.Data.Atomics (atomicModifyIORefCAS)

6060import Streamly.Streams.SVar (fromSVar)

6161import Streamly.Streams.Serial (map)

62−import Streamly.SVar

62+import Streamly.Internal.Data.SVar

6363import Streamly.Streams.StreamK

6464 (IsStream(..), Stream, mkStream, foldStream, adapt, foldStreamShared,

6565 foldStreamSVar)

src/Streamly/Streams/Combinators.hs+1−1

@@ -29,7 +29,7 @@ where

2929import Control.Monad.IO.Class (MonadIO(liftIO))

3030import Data.Int (Int64)

3131

32−import Streamly.SVar

32+import Streamly.Internal.Data.SVar

3333import Streamly.Streams.StreamK

3434import Streamly.Streams.Serial (SerialT)

3535

src/Streamly/Streams/Parallel.hs+1−1

@@ -58,7 +58,7 @@ import qualified Data.Set as Set

5858

5959import Streamly.Streams.SVar (fromSVar, fromStreamVar)

6060import Streamly.Streams.Serial (map)

61−import Streamly.SVar

61+import Streamly.Internal.Data.SVar

6262import Streamly.Streams.StreamK (IsStream(..), Stream, mkStream, foldStream,

6363 foldStreamShared, adapt)

6464import qualified Streamly.Streams.StreamK as K

src/Streamly/Streams/SVar.hs+1−1

@@ -31,7 +31,7 @@ import System.IO (hPutStrLn, stderr)

3131import Streamly.Time.Clock (Clock(Monotonic), getTime)

3232import System.Mem (performMajorGC)

3333

34−import Streamly.SVar

34+import Streamly.Internal.Data.SVar

3535import Streamly.Streams.StreamK hiding (reverse)

3636

3737printSVar :: SVar t m a -> String -> IO ()

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

@@ -301,7 +301,7 @@ import qualified Control.Monad.Catch as MC

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

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

303303import Streamly.Internal.Data.Pipe.Types (Pipe(..), PipeState(..))

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

304+import Streamly.Internal.Data.SVar (MonadAsync, defState, adaptState)

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

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

307307

src/Streamly/Streams/StreamD/Type.hs+1−1

@@ -71,7 +71,7 @@ import Control.Monad.Trans (lift, MonadTrans)

7171import GHC.Types (SPEC(..))

7272import Prelude hiding (map, mapM, foldr, take, concatMap)

7373

74−import Streamly.SVar (State(..), adaptState, defState)

74+import Streamly.Internal.Data.SVar (State(..), adaptState, defState)

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

7676

7777import qualified Streamly.Streams.StreamK as K

src/Streamly/Streams/StreamK.hs+1−1

@@ -194,7 +194,7 @@ import Prelude

194194 foldr1, (!!), replicate, reverse, concatMap)

195195import qualified Prelude

196196

197−import Streamly.SVar

197+import Streamly.Internal.Data.SVar

198198import Streamly.Streams.StreamK.Type

199199

200200-------------------------------------------------------------------------------

src/Streamly/Streams/StreamK/Type.hs+1−1

@@ -92,7 +92,7 @@ import Data.Semigroup (Semigroup(..))

9292#endif

9393import Prelude hiding (map, mapM, concatMap, foldr)

9494

95−import Streamly.SVar

95+import Streamly.Internal.Data.SVar

9696

9797------------------------------------------------------------------------------

9898-- Basic stream type

src/Streamly/Streams/Zip.hs+1−1

@@ -56,7 +56,7 @@ import Prelude hiding (map, repeat, zipWith)

5656import Streamly.Streams.StreamK (IsStream(..), Stream, mkStream, foldStream)

5757import Streamly.Streams.Async (mkAsync')

5858import Streamly.Streams.Serial (map)

59−import Streamly.SVar (MonadAsync, adaptState)

59+import Streamly.Internal.Data.SVar (MonadAsync, adaptState)

6060

6161import qualified Streamly.Streams.Prelude as P

6262import qualified Streamly.Streams.StreamK as K

streamly.cabal+4−4

@@ -252,8 +252,7 @@ library

252252 if os(darwin)

253253 c-sources: src/Streamly/Time/Darwin.c

254254 hs-source-dirs: src

255− other-modules: Streamly.SVar

256− , Streamly.Strict

255+ other-modules: Streamly.Strict

257256 , Streamly.Enumeration

258257

259258 -- Memory storage

@@ -305,6 +304,7 @@ library

305304 -- Internal modules

306305 , Streamly.Internal

307306 , Streamly.Internal.Data.Atomics

307+ , Streamly.Internal.Data.SVar

308308 , Streamly.Internal.Memory.Array.Types

309309 , Streamly.Internal.Memory.ArrayStream

310310 , Streamly.Internal.Data.Fold.Types

@@ -644,9 +644,9 @@ benchmark base

644644 hs-source-dirs: benchmark, src

645645 main-is: BaseStreams.hs

646646 other-modules: Streamly.Internal.Data.Atomics

647+ , Streamly.Internal.Data.SVar

647648 , Streamly.Time.Units

648649 , Streamly.Time.Clock

649− , Streamly.SVar

650650 , Streamly.Streams.StreamDK.Type

651651 , Streamly.Streams.StreamDK

652652 , Streamly.Streams.StreamK.Type

@@ -699,9 +699,9 @@ executable nano-bench

699699 c-sources: src/Streamly/Time/Darwin.c

700700 main-is: NanoBenchmarks.hs

701701 other-modules: Streamly.Internal.Data.Atomics

702+ , Streamly.Internal.Data.SVar

702703 , Streamly.Time.Units

703704 , Streamly.Time.Clock

704− , Streamly.SVar

705705 , Streamly.Streams.StreamK.Type

706706 , Streamly.Streams.StreamK

707707 , Streamly.Streams.StreamD.Type