b1d1902 · streamly · git.iko.soy

git.iko.soy/streamly

Move Streams/Serial.hs to Internal/Data/Stream

commitb1d1902b17566b0d9913b63574c632ec2595ad9c authoradithyaov <adi.obilisetty@gmail.com> dateMon 9 Dec 2019, 15:57 (7 years ago) parentb17c23e

21 files changed+24−24

compare with master

unifiedsplit

src/Streamly.hs+1−1

@@ -228,7 +228,7 @@ import Streamly.Internal.Data.Stream.Ahead

228228import Streamly.Internal.Data.Stream.Async

229229import Streamly.Internal.Data.Stream.Combinators

230230import Streamly.Streams.Parallel

231−import Streamly.Streams.Serial

231+import Streamly.Internal.Data.Stream.Serial

232232import Streamly.Internal.Data.Stream.StreamK hiding (serial)

233233import Streamly.Internal.Data.Stream.Zip

234234

src/Streamly/FileSystem/FD.hs+1−1

@@ -137,7 +137,7 @@ import qualified GHC.IO.FD as FD

137137import qualified GHC.IO.Device as RawIO

138138

139139import Streamly.Internal.Memory.Array.Types (Array(..), byteLength, defaultChunkSize)

140−import Streamly.Streams.Serial (SerialT)

140+import Streamly.Internal.Data.Stream.Serial (SerialT)

141141import Streamly.Internal.Data.Stream.StreamK.Type (IsStream, mkStream)

142142

143143#if !defined(mingw32_HOST_OS)

src/Streamly/Internal/Data/Array.hs+1−1

@@ -59,7 +59,7 @@ import qualified GHC.Exts as Exts

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

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

6161import Streamly.Internal.Data.Stream.StreamK.Type (IsStream)

62−import Streamly.Streams.Serial (SerialT)

62+import Streamly.Internal.Data.Stream.Serial (SerialT)

6363

6464import qualified Streamly.Internal.Data.Stream.StreamD as D

6565

src/Streamly/Internal/Data/List.hs+1−1

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

8484#endif

8585import GHC.Exts (IsList(..), IsString(..))

8686

87−import Streamly.Streams.Serial (SerialT)

87+import Streamly.Internal.Data.Stream.Serial (SerialT)

8888import Streamly.Internal.Data.Stream.Zip (ZipSerialM)

8989

9090import qualified Streamly.Streams.Prelude as P

src/Streamly/Internal/Data/Pipe.hs+1−1

@@ -257,7 +257,7 @@ import Streamly.Internal.Data.Pipe.Types

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

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

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

260−-- import Streamly.Streams.Serial (SerialT)

260+-- import Streamly.Internal.Data.Stream.Serial (SerialT)

261261-- import Streamly.Internal.Data.Stream.StreamK (IsStream())

262262-- import Streamly.Internal.Data.Time.Units

263263-- (AbsTime, MilliSecond64(..), addToAbsTime, diffAbsTime, toRelTime,

src/Streamly/Internal/Data/Stream/Ahead.hs+1−1

@@ -47,7 +47,7 @@ import GHC.Exts (inline)

4747import qualified Data.Heap as H

4848

4949import Streamly.Internal.Data.Stream.SVar (fromSVar)

50−import Streamly.Streams.Serial (map)

50+import Streamly.Internal.Data.Stream.Serial (map)

5151import Streamly.Internal.Data.SVar

5252import Streamly.Internal.Data.Stream.StreamK

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

src/Streamly/Internal/Data/Stream/Async.hs+1−1

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

5858

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

6060import Streamly.Internal.Data.Stream.SVar (fromSVar)

61−import Streamly.Streams.Serial (map)

61+import Streamly.Internal.Data.Stream.Serial (map)

6262import Streamly.Internal.Data.SVar

6363import Streamly.Internal.Data.Stream.StreamK

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

src/Streamly/Internal/Data/Stream/Combinators.hs+1−1

@@ -31,7 +31,7 @@ import Data.Int (Int64)

3131

3232import Streamly.Internal.Data.SVar

3333import Streamly.Internal.Data.Stream.StreamK

34−import Streamly.Streams.Serial (SerialT)

34+import Streamly.Internal.Data.Stream.Serial (SerialT)

3535

3636-------------------------------------------------------------------------------

3737-- Concurrency control

src/Streamly/Internal/Data/Stream/Enumeration.hs+1−1

@@ -66,7 +66,7 @@ import Streamly.Internal.Data.Stream.StreamD (fromStreamD)

6666import Streamly.Internal.Data.Stream.StreamK (IsStream(..))

6767

6868import qualified Streamly.Internal.Data.Stream.StreamD as D

69−import qualified Streamly.Streams.Serial as Serial

69+import qualified Streamly.Internal.Data.Stream.Serial as Serial

7070

7171-------------------------------------------------------------------------------

7272-- Enumeration of Integral types

src/Streamly/Streams/Serial.hs → src/Streamly/Internal/Data/Stream/Serial.hsrenamed+2−2

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

99{-# LANGUAGE UndecidableInstances #-} -- XXX

1010

1111-- |

12−-- Module : Streamly.Streams.Serial

12+-- Module : Streamly.Internal.Data.Stream.Serial

1414--

1515-- License : BSD3

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

1818-- Portability : GHC

1919--

2020--

21−module Streamly.Streams.Serial

21+module Streamly.Internal.Data.Stream.Serial

2222 (

2323 -- * Serial appending stream

2424 SerialT

src/Streamly/Internal/Data/Stream/Zip.hs+1−1

@@ -49,7 +49,7 @@ import Text.Read (Lexeme(Ident), lexP, parens, prec, readPrec, readListPrec,

4949import Prelude hiding (map, repeat, zipWith)

5050

5151import Streamly.Internal.Data.Stream.StreamK (IsStream(..), Stream)

52−import Streamly.Streams.Serial (map)

52+import Streamly.Internal.Data.Stream.Serial (map)

5353import Streamly.Internal.Data.SVar (MonadAsync)

5454import Streamly.Internal.Prelude (zipWith, zipAsyncWith)

5555

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

@@ -73,7 +73,7 @@ import Streamly.Internal.Data.Unfold.Types (Unfold(..))

7373-- import Streamly.Internal.Memory.Array.Types

7474-- (Array(..), writeNUnsafe, defaultChunkSize, shrinkToFit,

7575-- lpackArraysChunksOf)

76−-- import Streamly.Streams.Serial (SerialT)

76+-- import Streamly.Internal.Data.Stream.Serial (SerialT)

7777import Streamly.Internal.Data.Stream.StreamK.Type (IsStream)

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

7979

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

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

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

108108import Streamly.Internal.Memory.Array.Types

109109 (Array(..), defaultChunkSize, writeNUnsafe)

110−import Streamly.Streams.Serial (SerialT)

110+import Streamly.Internal.Data.Stream.Serial (SerialT)

111111import Streamly.Internal.Data.Stream.StreamK.Type (IsStream)

112112import Streamly.Internal.Data.SVar (MonadAsync)

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

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

@@ -124,7 +124,7 @@ import Streamly.Internal.Data.Unfold.Types (Unfold(..))

124124import Streamly.Internal.Memory.Array.Types

125125 (Array(..), writeNUnsafe, defaultChunkSize, shrinkToFit,

126126 lpackArraysChunksOf)

127−import Streamly.Streams.Serial (SerialT)

127+import Streamly.Internal.Data.Stream.Serial (SerialT)

128128import Streamly.Internal.Data.Stream.StreamK.Type (IsStream, mkStream)

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

130130

src/Streamly/Internal/Memory/Array.hs+2−2

@@ -142,12 +142,12 @@ import GHC.IO (IO(..))

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

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

144144import Streamly.Internal.Memory.Array.Types (Array(..), length)

145−import Streamly.Streams.Serial (SerialT)

145+import Streamly.Internal.Data.Stream.Serial (SerialT)

146146import Streamly.Internal.Data.Stream.StreamK.Type (IsStream)

147147

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

149149import qualified Streamly.Streams.Prelude as P

150−import qualified Streamly.Streams.Serial as Serial

150+import qualified Streamly.Internal.Data.Stream.Serial as Serial

151151import qualified Streamly.Internal.Data.Stream.StreamD as D

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

153153

src/Streamly/Internal/Memory/ArrayStream.hs+1−1

@@ -50,7 +50,7 @@ import Foreign.Storable (Storable(..))

5050import Prelude hiding (length, null, last, map, (!!), read, concat)

5151

5252import Streamly.Internal.Memory.Array.Types (Array(..), length)

53−import Streamly.Streams.Serial (SerialT)

53+import Streamly.Internal.Data.Stream.Serial (SerialT)

5454import Streamly.Internal.Data.Stream.StreamK.Type (IsStream)

5555

5656import qualified Streamly.Internal.Memory.Array as A

src/Streamly/Internal/Network/Inet/TCP.hs+1−1

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

112112import Streamly.Internal.Data.SVar (fork)

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

114114import Streamly.Internal.Network.Socket (SockSpec(..), accept, connections)

115−import Streamly.Streams.Serial (SerialT)

115+import Streamly.Internal.Data.Stream.Serial (SerialT)

116116import Streamly.Internal.Memory.Array.Types (Array(..), defaultChunkSize, writeNUnsafe)

117117import Streamly.Internal.Data.Stream.StreamK.Type (IsStream)

118118

src/Streamly/Internal/Network/Socket.hs+1−1

@@ -95,7 +95,7 @@ import qualified Network.Socket as Net

9595import Streamly (MonadAsync)

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

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

98−import Streamly.Streams.Serial (SerialT)

98+import Streamly.Internal.Data.Stream.Serial (SerialT)

9999import Streamly.Internal.Data.Stream.StreamK.Type (IsStream, mkStream)

100100import Streamly.Data.Fold (Fold)

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

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

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

453453 (fromStreamS, toStreamS, foldWith, foldMapWith, forEachWith)

454454import Streamly.Internal.Data.Stream.StreamD (fromStreamD, toStreamD)

455455import Streamly.Internal.Data.Stream.StreamK (IsStream((|:), consM))

456−import Streamly.Streams.Serial (SerialT)

456+import Streamly.Internal.Data.Stream.Serial (SerialT)

457457import Streamly.Internal.Data.Pipe.Types (Pipe (..))

458458import Streamly.Internal.Data.Time.Units

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

@@ -474,7 +474,7 @@ import qualified Streamly.Internal.Data.Stream.StreamK as S

474474import qualified Streamly.Internal.Data.Stream.StreamD as S

475475#endif

476476

477−import qualified Streamly.Streams.Serial as Serial

477+import qualified Streamly.Internal.Data.Stream.Serial as Serial

478478import qualified Streamly.Streams.Parallel as Par

479479

480480------------------------------------------------------------------------------

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

@@ -55,7 +55,7 @@ import Prelude hiding (map)

5555import qualified Data.Set as Set

5656

5757import Streamly.Internal.Data.Stream.SVar (fromSVar, fromStreamVar)

58−import Streamly.Streams.Serial (map)

58+import Streamly.Internal.Data.Stream.Serial (map)

5959import Streamly.Internal.Data.Stream.StreamK (IsStream(..), Stream, mkStream, foldStream,

6060 foldStreamShared, adapt)

6161

streamly.cabal+1−1

@@ -288,7 +288,7 @@ library

288288

289289 -- Higher level streams

290290 , Streamly.Internal.Data.Stream.SVar

291− , Streamly.Streams.Serial

291+ , Streamly.Internal.Data.Stream.Serial

292292 , Streamly.Internal.Data.Stream.Async

293293 , Streamly.Streams.Parallel

294294 , Streamly.Internal.Data.Stream.Ahead