b1d1902 · streamly · git.iko.soy

src/Streamly.hs+1−1

compare with master

unifiedsplit

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

228import Streamly.Internal.Data.Stream.Async

229import Streamly.Internal.Data.Stream.Combinators

230import Streamly.Streams.Parallel

231−import Streamly.Streams.Serial

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

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

233import Streamly.Internal.Data.Stream.Zip

234

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

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

137import qualified GHC.IO.Device as RawIO

138

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

140−import Streamly.Streams.Serial (SerialT)

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

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

142

143#if !defined(mingw32_HOST_OS)

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

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

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

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

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

62−import Streamly.Streams.Serial (SerialT)

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

63

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

65

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

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

84#endif

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

86

87−import Streamly.Streams.Serial (SerialT)

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

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

89

90import qualified Streamly.Streams.Prelude as P

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

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

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

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

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

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

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

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

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

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

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

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

47import qualified Data.Heap as H

48

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

50−import Streamly.Streams.Serial (map)

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

51import Streamly.Internal.Data.SVar

52import Streamly.Internal.Data.Stream.StreamK

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

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

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

58

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

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

61−import Streamly.Streams.Serial (map)

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

62import Streamly.Internal.Data.SVar

63import Streamly.Internal.Data.Stream.StreamK

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

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

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

31

32import Streamly.Internal.Data.SVar

33import Streamly.Internal.Data.Stream.StreamK

34−import Streamly.Streams.Serial (SerialT)

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

35

36-------------------------------------------------------------------------------

37-- Concurrency control

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

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

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

67

68import 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

70

71-------------------------------------------------------------------------------

72-- Enumeration of Integral types

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

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

9{-# LANGUAGE UndecidableInstances #-} -- XXX

10

11-- |

12−-- Module : Streamly.Streams.Serial

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

14--

15-- License : BSD3

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

18-- Portability : GHC

19--

20--

21−module Streamly.Streams.Serial

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

22 (

23 -- * Serial appending stream

24 SerialT

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

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

49import Prelude hiding (map, repeat, zipWith)

50

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

52−import Streamly.Streams.Serial (map)

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

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

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

55

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

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

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

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

75-- lpackArraysChunksOf)

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

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

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

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

79

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

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

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

108import Streamly.Internal.Memory.Array.Types

109 (Array(..), defaultChunkSize, writeNUnsafe)

110−import Streamly.Streams.Serial (SerialT)

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

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

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

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

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

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

124import Streamly.Internal.Memory.Array.Types

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

126 lpackArraysChunksOf)

127−import Streamly.Streams.Serial (SerialT)

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

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

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

130

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

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

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

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

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

145−import Streamly.Streams.Serial (SerialT)

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

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

147

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

149import qualified Streamly.Streams.Prelude as P

150−import qualified Streamly.Streams.Serial as Serial

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

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

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

153

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

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

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

51

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

53−import Streamly.Streams.Serial (SerialT)

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

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

55

56import 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(..))

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

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

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

115−import Streamly.Streams.Serial (SerialT)

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

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

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

118

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

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

95import Streamly (MonadAsync)

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

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

98−import Streamly.Streams.Serial (SerialT)

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

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

100import Streamly.Data.Fold (Fold)

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

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

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

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

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

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

456−import Streamly.Streams.Serial (SerialT)

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

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

458import Streamly.Internal.Data.Time.Units

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

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

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

475#endif

476

477−import qualified Streamly.Streams.Serial as Serial

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

478import qualified Streamly.Streams.Parallel as Par

479

480------------------------------------------------------------------------------

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

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

55import qualified Data.Set as Set

56

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

58−import Streamly.Streams.Serial (map)

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

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

60 foldStreamShared, adapt)

61

streamly.cabal+1−1

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

288

289 -- Higher level streams

290 , Streamly.Internal.Data.Stream.SVar

291− , Streamly.Streams.Serial

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

292 , Streamly.Internal.Data.Stream.Async

293 , Streamly.Streams.Parallel

294 , Streamly.Internal.Data.Stream.Ahead