87ebad5 · streamly · git.iko.soy

.hlint.ignore+6−6

compare with master

unifiedsplit

@@ -16,15 +16,15 @@ src/Streamly/Internal/Data/Stream/StreamD/Transform.hs

16src/Streamly/Internal/Data/Stream/StreamD/Exception.hs

17src/Streamly/Internal/Data/Stream/StreamD/Lift.hs

18src/Streamly/Internal/Data/Stream/StreamD/Nesting.hs

19−src/Streamly/Internal/Data/Pipe/Types.hs

19+src/Streamly/Internal/Data/Pipe/Type.hs

20−src/Streamly/Internal/Data/SmallArray/Types.hs

20+src/Streamly/Internal/Data/SmallArray/Type.hs

21src/Streamly/Internal/Unicode/Stream.hs

22src/Streamly/Internal/Data/IORef/Prim.hs

23−src/Streamly/Internal/Data/Array/Prim/Types.hs

23+src/Streamly/Internal/Data/Array/Prim/Type.hs

24−src/Streamly/Internal/Data/Array/Prim/Mut/Types.hs

24+src/Streamly/Internal/Data/Array/Prim/Mut/Type.hs

25src/Streamly/Internal/Data/Array/Prim/MutTypesInclude.hs

26−src/Streamly/Internal/Data/Array/Prim/Pinned/Mut/Types.hs

26+src/Streamly/Internal/Data/Array/Prim/Pinned/Mut/Type.hs

27−src/Streamly/Internal/Data/Array/Prim/Pinned/Types.hs

27+src/Streamly/Internal/Data/Array/Prim/Pinned/Type.hs

28src/Streamly/Internal/Data/Array/Prim/TypesInclude.hs

29test/Streamly/Test/Common/Array.hs

30test/Streamly/Test/Data/Array.hs

benchmark/Streamly/Benchmark/Data/Fold.hs+1−1

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

19

20import qualified Data.Map.Strict as Map

21import qualified Streamly.Internal.Data.Fold as FL

22−import qualified Streamly.Internal.Data.Fold.Types as FL

22+import qualified Streamly.Internal.Data.Fold.Type as FL

23import qualified Streamly.Internal.Data.Pipe as Pipe

24import qualified Streamly.Internal.Data.Sink as Sink

25import qualified Streamly.Internal.Data.Stream.IsStream as IP

benchmark/Streamly/Benchmark/Data/Parser/ParserK.hs+1−1

@@ -24,7 +24,7 @@ import qualified Data.Foldable as F

24import qualified Data.Traversable as TR

25import qualified Streamly.Prelude as S

26import qualified Streamly.Internal.Data.Fold as FL

27−import qualified Streamly.Internal.Data.Parser.ParserK.Types as PR

27+import qualified Streamly.Internal.Data.Parser.ParserK.Type as PR

28import qualified Streamly.Internal.Data.Parser.ParserD as PRD

29import qualified Streamly.Internal.Data.Stream.IsStream as IP

30

benchmark/Streamly/Benchmark/FileSystem/Handle/Read.hs+2−2

@@ -34,7 +34,7 @@ import System.IO (Handle)

34

35import qualified Streamly.FileSystem.Handle as FH

36import qualified Streamly.Internal.Data.Array.Foreign as A

37−import qualified Streamly.Internal.Data.Array.Foreign.Types as AT

37+import qualified Streamly.Internal.Data.Array.Foreign.Type as AT

38import qualified Streamly.Internal.Data.Fold as FL

39import qualified Streamly.Internal.Data.Stream.IsStream as IP

40import qualified Streamly.Internal.FileSystem.Handle as IFH

@@ -50,7 +50,7 @@ import Streamly.Benchmark.Common.Handle

50#ifdef INSPECTION

51import Streamly.Internal.Data.Stream.StreamD.Type (Step(..), FoldMany)

52

53−import qualified Streamly.Internal.Data.Array.Foreign.Mut.Types as MA

53+import qualified Streamly.Internal.Data.Array.Foreign.Mut.Type as MA

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

55import qualified Streamly.Internal.Data.Unfold as IUF

56

benchmark/Streamly/Benchmark/FileSystem/Handle/ReadWrite.hs+3−3

@@ -24,7 +24,7 @@ where

24

25import System.IO (Handle)

26import Prelude hiding (last, length)

27−import Streamly.Internal.Data.Array.Foreign.Types (defaultChunkSize)

27+import Streamly.Internal.Data.Array.Foreign.Type (defaultChunkSize)

28

29import qualified Streamly.FileSystem.Handle as FH

30import qualified Streamly.Internal.Data.Unfold as IUF

@@ -43,8 +43,8 @@ import Streamly.Internal.Data.Stream.StreamD.Type (Step(..))

43import qualified Streamly.Internal.Data.Stream.StreamD.Type as D

44import qualified Streamly.Internal.Data.Tuple.Strict as Strict

45import qualified Streamly.Internal.Data.Array.Stream.Mut.Foreign as MAS

46−import qualified Streamly.Internal.Data.Array.Foreign.Types as AT

46+import qualified Streamly.Internal.Data.Array.Foreign.Type as AT

47−import qualified Streamly.Internal.Data.Array.Foreign.Mut.Types as MA

47+import qualified Streamly.Internal.Data.Array.Foreign.Mut.Type as MA

48

49import Test.Inspection

50#endif

benchmark/Streamly/Benchmark/Prelude/Serial/Split.hs+1−1

@@ -41,7 +41,7 @@ import Streamly.Benchmark.Common.Handle

41#ifdef INSPECTION

42import Streamly.Internal.Data.Stream.StreamD.Type (Step(..))

43

44−import qualified Streamly.Internal.Data.Array.Foreign.Mut.Types as MA

44+import qualified Streamly.Internal.Data.Array.Foreign.Mut.Type as MA

45import qualified Streamly.Internal.Data.Unfold as IUF

46

47import Test.Inspection

benchmark/Streamly/Benchmark/Unicode/Stream.hs+2−2

@@ -40,8 +40,8 @@ import Streamly.Benchmark.Common.Handle

40import Foreign.Storable (Storable)

41import Streamly.Internal.Data.Stream.StreamD.Type (Step(..))

42import qualified Streamly.Internal.Data.Tuple.Strict as Strict

43−import qualified Streamly.Internal.Data.Array.Foreign.Types as AT

43+import qualified Streamly.Internal.Data.Array.Foreign.Type as AT

44−import qualified Streamly.Internal.Data.Array.Foreign.Mut.Types as MA

44+import qualified Streamly.Internal.Data.Array.Foreign.Mut.Type as MA

45

46import Test.Inspection

47#endif

src/Streamly/FileSystem/Handle.hs+2−2

@@ -44,12 +44,12 @@ module Streamly.FileSystem.Handle

44 -- the stream is lazy and generated on-demand as the consumer consumes it.

45 -- Read IO requests to the IO device are performed in chunks limited to a

46 -- maximum size of 32KiB, this is referred to as

47− -- 'Streamly.Internal.Data.Array.Foreign.Types.defaultChunkSize' in the

47+ -- 'Streamly.Internal.Data.Array.Foreign.Type.defaultChunkSize' in the

48 -- documentation. One IO request may or may not read the full

49 -- chunk. If the whole stream is not consumed, it is possible that we may

50 -- read slightly more from the IO device than what the consumer needed.

51 -- Unless specified otherwise in the API, writes are collected into chunks

52− -- of 'Streamly.Internal.Data.Array.Foreign.Types.defaultChunkSize' before they

52+ -- of 'Streamly.Internal.Data.Array.Foreign.Type.defaultChunkSize' before they

53 -- are written to the IO device.

54

55 -- Streaming APIs work for all kind of devices, seekable or non-seekable;

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

@@ -55,13 +55,13 @@ import GHC.Base (Int(..))

55import GHC.IO (unsafePerformIO)

56import qualified GHC.Exts as Exts

57

58−import Streamly.Internal.Data.Fold.Types (Fold(..))

58+import Streamly.Internal.Data.Fold.Type (Fold(..))

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

60import Streamly.Internal.Data.Stream.Serial (SerialT)

61import Streamly.Internal.Data.Tuple.Strict (Tuple'(..), Tuple3'(..))

62−import Streamly.Internal.Data.Unfold.Types (Unfold(..))

62+import Streamly.Internal.Data.Unfold.Type (Unfold(..))

63

64−import qualified Streamly.Internal.Data.Fold.Types as FL

64+import qualified Streamly.Internal.Data.Fold.Type as FL

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

66

67{-# NOINLINE bottomElement #-}

src/Streamly/Internal/Data/Array/Foreign.hs+5−5

@@ -158,15 +158,15 @@ import GHC.Ptr (Ptr(..))

158import GHC.Prim (touch#)

159import GHC.IO (IO(..))

160

161−import Streamly.Internal.Data.Array.Foreign.Types (Array(..), length)

161+import Streamly.Internal.Data.Array.Foreign.Type (Array(..), length)

162−import Streamly.Internal.Data.Fold.Types (Fold(..))

162+import Streamly.Internal.Data.Fold.Type (Fold(..))

163import Streamly.Internal.Data.Producer.Type (Producer)

164import Streamly.Internal.Data.Stream.Serial (SerialT)

165import Streamly.Internal.Data.Tuple.Strict (Tuple3'(..))

166−import Streamly.Internal.Data.Unfold.Types (Unfold(..))

166+import Streamly.Internal.Data.Unfold.Type (Unfold(..))

167

168−import qualified Streamly.Internal.Data.Array.Foreign.Mut.Types as MA

168+import qualified Streamly.Internal.Data.Array.Foreign.Mut.Type as MA

169−import qualified Streamly.Internal.Data.Array.Foreign.Types as A

169+import qualified Streamly.Internal.Data.Array.Foreign.Type as A

170import qualified Streamly.Internal.Data.Fold as FL

171import qualified Streamly.Internal.Data.Stream.Prelude as P

172import qualified Streamly.Internal.Data.Stream.Serial as Serial

src/Streamly/Internal/Data/Array/Foreign/Mut/Types.hs → src/Streamly/Internal/Data/Array/Foreign/Mut/Type.hsrenamed+6−6

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

1{-# LANGUAGE UnboxedTuples #-}

2

3-- |

4−-- Module : Streamly.Internal.Data.Array.Foreign.Mut.Types

4+-- Module : Streamly.Internal.Data.Array.Foreign.Mut.Type

6-- License : BSD3-3-Clause

7-- Maintainer : streamly@composewell.com

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

22-- Stream and Fold APIs allow easy, efficient and convenient operations on

23-- arrays.

24

25−module Streamly.Internal.Data.Array.Foreign.Mut.Types

25+module Streamly.Internal.Data.Array.Foreign.Mut.Type

26 (

27 -- * Type

28 -- $arrayNotes

@@ -135,17 +135,17 @@ import GHC.Exts (IsList, IsString(..))

135import GHC.ForeignPtr (ForeignPtr(..))

136import GHC.IO (IO(IO), unsafePerformIO)

137import GHC.Ptr (Ptr(..))

138−import Streamly.Internal.Data.Fold.Types (Fold(..))

138+import Streamly.Internal.Data.Fold.Type (Fold(..))

139import Streamly.Internal.Data.Producer.Type (Producer (..))

140import Streamly.Internal.Data.SVar (adaptState)

141−import Streamly.Internal.Data.Unfold.Types (Unfold(..))

141+import Streamly.Internal.Data.Unfold.Type (Unfold(..))

142import Text.Read (readPrec, readListPrec, readListPrecDefault)

143

144#ifdef DEVBUILD

145import qualified Data.Foldable as F

146#endif

147import qualified GHC.Exts as Exts

148−import qualified Streamly.Internal.Data.Fold.Types as FL

148+import qualified Streamly.Internal.Data.Fold.Type as FL

149import qualified Streamly.Internal.Data.Producer as Producer

150import qualified Streamly.Internal.Data.Stream.StreamD.Type as D

151import qualified Streamly.Internal.Data.Stream.StreamK.Type as K

@@ -463,7 +463,7 @@ arraysOf n (D.Stream step state) =

463 step' _ (GroupStart st) = do

464 when (n <= 0) $

465 -- XXX we can pass the module string from the higher level API

466− error $ "Streamly.Internal.Data.Array.Foreign.Mut.Types.fromStreamDArraysOf: the size of "

466+ error $ "Streamly.Internal.Data.Array.Foreign.Mut.Type.fromStreamDArraysOf: the size of "

467 ++ "arrays [" ++ show n ++ "] must be a natural number"

468 Array start end bound <- liftIO $ newArray n

469 return $ D.Skip (GroupBuffer st start end bound)

src/Streamly/Internal/Data/Array/Foreign/Types.hs → src/Streamly/Internal/Data/Array/Foreign/Type.hsrenamed+7−7

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

1#include "inline.hs"

2

3-- |

4−-- Module : Streamly.Internal.Data.Array.Foreign.Types

4+-- Module : Streamly.Internal.Data.Array.Foreign.Type

6--

7-- License : BSD3-3-Clause

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

9-- Stability : experimental

10-- Portability : GHC

11--

12−-- See notes in "Streamly.Internal.Data.Array.Foreign.Mut.Types"

12+-- See notes in "Streamly.Internal.Data.Array.Foreign.Mut.Type"

13--

14−module Streamly.Internal.Data.Array.Foreign.Types

14+module Streamly.Internal.Data.Array.Foreign.Type

15 (

16 -- $arrayNotes

17 Array (..)

@@ -97,16 +97,16 @@ import GHC.ForeignPtr (touchForeignPtr, unsafeForeignPtrToPtr)

97#endif

98import GHC.IO (unsafePerformIO)

99import GHC.Ptr (Ptr(..))

100−import Streamly.Internal.Data.Fold.Types (Fold(..))

100+import Streamly.Internal.Data.Fold.Type (Fold(..))

101−import Streamly.Internal.Data.Unfold.Types (Unfold(..))

101+import Streamly.Internal.Data.Unfold.Type (Unfold(..))

102import Text.Read (readPrec, readListPrec, readListPrecDefault)

103

104import Prelude hiding (length, foldr, read, unlines, splitAt)

105

106−import qualified Streamly.Internal.Data.Array.Foreign.Mut.Types as MA

106+import qualified Streamly.Internal.Data.Array.Foreign.Mut.Type as MA

107import qualified Streamly.Internal.Data.Stream.StreamD.Type as D

108import qualified Streamly.Internal.Data.Stream.StreamK.Type as K

109−import qualified Streamly.Internal.Data.Unfold.Types as Unfold

109+import qualified Streamly.Internal.Data.Unfold.Type as Unfold

110import qualified GHC.Exts as Exts

111

112#if __GLASGOW_HASKELL__ < 808

src/Streamly/Internal/Data/Array/Prim.hs+2−2

@@ -104,7 +104,7 @@ module Streamly.Internal.Data.Array.Prim

104 )

105where

106

107−import Streamly.Internal.Data.Array.Prim.Types (Array(..), length)

107+import Streamly.Internal.Data.Array.Prim.Type (Array(..), length)

108−import qualified Streamly.Internal.Data.Array.Prim.Types as A

108+import qualified Streamly.Internal.Data.Array.Prim.Type as A

109

110#include "Streamly/Internal/Data/Array/PrimInclude.hs"

src/Streamly/Internal/Data/Array/Prim/Mut/Types.hs → src/Streamly/Internal/Data/Array/Prim/Mut/Type.hsrenamed+2−2

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

3#include "inline.hs"

4

5-- |

6−-- Module : Streamly.Internal.Data.Array.Prim.Mut.Types

6+-- Module : Streamly.Internal.Data.Array.Prim.Mut.Type

8--

9-- License : BSD-3-Clause

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

11-- Stability : experimental

12-- Portability : GHC

13--

14−module Streamly.Internal.Data.Array.Prim.Mut.Types

14+module Streamly.Internal.Data.Array.Prim.Mut.Type

15 (

16 Array (..)

17

src/Streamly/Internal/Data/Array/Prim/MutTypesInclude.hs+4−4

@@ -8,7 +8,7 @@ import Control.Monad (when)

8import Control.Monad.IO.Class (MonadIO(..))

9import Data.Bifunctor (first)

10import Data.Primitive.Types (Prim(..), sizeOf)

11−import Streamly.Internal.Data.Fold.Types (Fold(..))

11+import Streamly.Internal.Data.Fold.Type (Fold(..))

12import Streamly.Internal.Data.SVar (adaptState)

13import Streamly.Internal.Data.Tuple.Strict (Tuple'(..), Tuple3'(..))

14

@@ -266,7 +266,7 @@ fromStreamDArraysOf n (D.Stream step state) = D.Stream step' (GroupStart state)

266 when (n <= 0) $

267 -- XXX we can pass the module string from the higher level API

268 error $

269− "Streamly.Internal.Data.Array.Foreign.Mut.Types.fromStreamDArraysOf: the size of " ++

269+ "Streamly.Internal.Data.Array.Foreign.Mut.Type.fromStreamDArraysOf: the size of " ++

270 "arrays [" ++ show n ++ "] must be a natural number"

271 arr <- newArray n

272 return $ D.Skip (GroupBuffer st arr 0)

@@ -319,7 +319,7 @@ packArraysChunksOf n (D.Stream step state) =

319 step' gst (SpliceInitial st) = do

320 when (n <= 0) $

321 -- XXX we can pass the module string from the higher level API

322− error $ "Streamly.Internal.Data.Array.Foreign.Mut.Types.packArraysChunksOf: the size of "

322+ error $ "Streamly.Internal.Data.Array.Foreign.Mut.Type.packArraysChunksOf: the size of "

323 ++ "arrays [" ++ show n ++ "] must be a natural number"

324 r <- step gst st

325 case r of

@@ -364,7 +364,7 @@ lpackArraysChunksOf n (Fold step1 initial1 extract1) =

364 when (n <= 0)

365 -- XXX we can pass the module string from the higher level API

366 $ error

367− $ "Streamly.Internal.Data.Array.Foreign.Mut.Types."

367+ $ "Streamly.Internal.Data.Array.Foreign.Mut.Type."

368 ++ "packArraysChunksOf: the size of arrays ["

369 ++ show n

370 ++ "] must be a natural number"

src/Streamly/Internal/Data/Array/Prim/Pinned.hs+2−2

@@ -102,7 +102,7 @@ module Streamly.Internal.Data.Array.Prim.Pinned

102 )

103where

104

105−import Streamly.Internal.Data.Array.Prim.Pinned.Types (Array(..), length)

105+import Streamly.Internal.Data.Array.Prim.Pinned.Type (Array(..), length)

106−import qualified Streamly.Internal.Data.Array.Prim.Pinned.Types as A

106+import qualified Streamly.Internal.Data.Array.Prim.Pinned.Type as A

107

108#include "Streamly/Internal/Data/Array/PrimInclude.hs"

src/Streamly/Internal/Data/Array/Prim/Pinned/Mut/Types.hs → src/Streamly/Internal/Data/Array/Prim/Pinned/Mut/Type.hsrenamed+2−2

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

3#include "inline.hs"

4

5-- |

6−-- Module : Streamly.Internal.Data.Array.Prim.Pinned.Mut.Types

6+-- Module : Streamly.Internal.Data.Array.Prim.Pinned.Mut.Type

8--

9-- License : BSD-3-Clause

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

11-- Stability : experimental

12-- Portability : GHC

13--

14−module Streamly.Internal.Data.Array.Prim.Pinned.Mut.Types

14+module Streamly.Internal.Data.Array.Prim.Pinned.Mut.Type

15 (

16 Array (..)

17

src/Streamly/Internal/Data/Array/Prim/Pinned/Types.hs → src/Streamly/Internal/Data/Array/Prim/Pinned/Type.hsrenamed+3−3

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

3#include "inline.hs"

4

5-- |

6−-- Module : Streamly.Internal.Data.Array.Prim.Pinned.Types

6+-- Module : Streamly.Internal.Data.Array.Prim.Pinned.Type

8--

9-- License : BSD-3-Clause

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

11-- Stability : experimental

12-- Portability : GHC

13--

14−module Streamly.Internal.Data.Array.Prim.Pinned.Types

14+module Streamly.Internal.Data.Array.Prim.Pinned.Type

15 (

16 Array (..)

17 , unsafeFreeze

@@ -77,7 +77,7 @@ import Foreign.C.Types (CSize(..))

77import GHC.IO (IO(..))

78import Foreign.Ptr (minusPtr, nullPtr, plusPtr)

79

80−import qualified Streamly.Internal.Data.Array.Prim.Pinned.Mut.Types as MA

80+import qualified Streamly.Internal.Data.Array.Prim.Pinned.Mut.Type as MA

81

82#include "Streamly/Internal/Data/Array/Prim/TypesInclude.hs"

83

src/Streamly/Internal/Data/Array/Prim/Types.hs → src/Streamly/Internal/Data/Array/Prim/Type.hsrenamed+3−3

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

3#include "inline.hs"

4

5-- |

6−-- Module : Streamly.Internal.Data.Array.Prim.Types

6+-- Module : Streamly.Internal.Data.Array.Prim.Type

8--

9-- License : BSD-3-Clause

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

11-- Stability : experimental

12-- Portability : GHC

13--

14−module Streamly.Internal.Data.Array.Prim.Types

14+module Streamly.Internal.Data.Array.Prim.Type

15 (

16 Array (..)

17 , unsafeFreeze

@@ -68,7 +68,7 @@ module Streamly.Internal.Data.Array.Prim.Types

68 )

69where

70

71−import qualified Streamly.Internal.Data.Array.Prim.Mut.Types as MA

71+import qualified Streamly.Internal.Data.Array.Prim.Mut.Type as MA

72

73#include "Streamly/Internal/Data/Array/Prim/TypesInclude.hs"

74

src/Streamly/Internal/Data/Array/Prim/TypesInclude.hs+3−3

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

16import Data.Word (Word8)

17import Streamly.Internal.Data.Tuple.Strict (Tuple3'(..))

18import Streamly.Internal.Data.Maybe.Strict (Maybe'(..))

19−import Streamly.Internal.Data.Fold.Types (Fold(..))

19+import Streamly.Internal.Data.Fold.Type (Fold(..))

20import Streamly.Internal.Data.SVar (adaptState)

21import System.IO.Unsafe (unsafePerformIO)

22import Text.Read (readPrec, readListPrec, readListPrecDefault)

@@ -552,7 +552,7 @@ packArraysChunksOf n (D.Stream step state) =

552 step' gst (SpliceInitial st) = do

553 when (n <= 0) $

554 -- XXX we can pass the module string from the higher level API

555− error $ "Streamly.Internal.Data.Array.Foreign.Types.packArraysChunksOf: the size of "

555+ error $ "Streamly.Internal.Data.Array.Foreign.Type.packArraysChunksOf: the size of "

556 ++ "arrays [" ++ show n ++ "] must be a natural number"

557 r <- step gst st

558 case r of

@@ -602,7 +602,7 @@ lpackArraysChunksOf n (Fold step1 initial1 extract1) =

602 initial = do

603 when (n <= 0) $

604 -- XXX we can pass the module string from the higher level API

605− error $ "Streamly.Internal.Data.Array.Foreign.Types.packArraysChunksOf: the size of "

605+ error $ "Streamly.Internal.Data.Array.Foreign.Type.packArraysChunksOf: the size of "

606 ++ "arrays [" ++ show n ++ "] must be a natural number"

607 res <- initial1

608 return $ first (Tuple3' Nothing' 0) res

src/Streamly/Internal/Data/Array/PrimInclude.hs+2−2

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

7import Control.Monad (when)

8import Control.Monad.IO.Class (MonadIO(..))

9import Data.Primitive.Types (Prim(..))

10−import Streamly.Internal.Data.Fold.Types (Fold(..))

10+import Streamly.Internal.Data.Fold.Type (Fold(..))

11−import Streamly.Internal.Data.Unfold.Types (Unfold(..))

11+import Streamly.Internal.Data.Unfold.Type (Unfold(..))

12import Streamly.Internal.Data.Stream.Serial (SerialT)

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

14

src/Streamly/Internal/Data/Array/Stream/Foreign.hs+5−5

@@ -52,17 +52,17 @@ import Prelude hiding (length, null, last, map, (!!), read, concat, unlines)

52#if !defined(mingw32_HOST_OS)

53import Streamly.Internal.FileSystem.FDIO (IOVec(..))

54#endif

55−import Streamly.Internal.Data.Array.Foreign.Types (Array(..), length)

55+import Streamly.Internal.Data.Array.Foreign.Type (Array(..), length)

56−import Streamly.Internal.Data.Fold.Types (Fold(..))

56+import Streamly.Internal.Data.Fold.Type (Fold(..))

57import Streamly.Internal.Data.Stream.Serial (SerialT)

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

59import Streamly.Internal.Data.SVar (adaptState)

60

61import qualified Streamly.Internal.Data.Array.Foreign as A

62−import qualified Streamly.Internal.Data.Array.Foreign.Types as A

62+import qualified Streamly.Internal.Data.Array.Foreign.Type as A

63−import qualified Streamly.Internal.Data.Array.Foreign.Mut.Types as MA

63+import qualified Streamly.Internal.Data.Array.Foreign.Mut.Type as MA

64import qualified Streamly.Internal.Data.Array.Stream.Mut.Foreign as AS

65−import qualified Streamly.Internal.Data.Fold.Types as FL

65+import qualified Streamly.Internal.Data.Fold.Type as FL

66import qualified Streamly.Internal.Data.Stream.IsStream as S

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

68

src/Streamly/Internal/Data/Array/Stream/Mut/Foreign.hs+9−9

@@ -37,17 +37,17 @@ import Foreign.Storable (Storable(..))

37import Foreign.ForeignPtr.Unsafe (unsafeForeignPtrToPtr)

38import Foreign.Ptr (castPtr)

39import Streamly.Internal.FileSystem.FDIO (IOVec(..))

40−import Streamly.Internal.Data.Array.Foreign.Mut.Types (length)

40+import Streamly.Internal.Data.Array.Foreign.Mut.Type (length)

41import Streamly.Internal.Data.SVar (adaptState)

42#endif

43−import Streamly.Internal.Data.Array.Foreign.Mut.Types (Array(..))

43+import Streamly.Internal.Data.Array.Foreign.Mut.Type (Array(..))

44−import Streamly.Internal.Data.Fold.Types (Fold(..))

44+import Streamly.Internal.Data.Fold.Type (Fold(..))

45import Streamly.Internal.Data.Stream.Serial (SerialT)

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

47import Streamly.Internal.Data.Tuple.Strict (Tuple'(..))

48

49−import qualified Streamly.Internal.Data.Array.Foreign.Mut.Types as MArray

49+import qualified Streamly.Internal.Data.Array.Foreign.Mut.Type as MArray

50−import qualified Streamly.Internal.Data.Fold.Types as FL

50+import qualified Streamly.Internal.Data.Fold.Type as FL

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

52

53import Prelude hiding (length)

@@ -99,7 +99,7 @@ packArraysChunksOf n (D.Stream step state) =

99 step' gst (SpliceInitial st) = do

100 when (n <= 0) $

101 -- XXX we can pass the module string from the higher level API

102− error $ "Streamly.Internal.Data.Array.Foreign.Mut.Types.packArraysChunksOf: the size of "

102+ error $ "Streamly.Internal.Data.Array.Foreign.Mut.Type.packArraysChunksOf: the size of "

103 ++ "arrays [" ++ show n ++ "] must be a natural number"

104 r <- step gst st

105 case r of

@@ -143,7 +143,7 @@ lpackArraysChunksOf n (Fold step1 initial1 extract1) =

143 initial = do

144 when (n <= 0) $

145 -- XXX we can pass the module string from the higher level API

146− error $ "Streamly.Internal.Data.Array.Foreign.Mut.Types.packArraysChunksOf: the size of "

146+ error $ "Streamly.Internal.Data.Array.Foreign.Mut.Type.packArraysChunksOf: the size of "

147 ++ "arrays [" ++ show n ++ "] must be a natural number"

148

149 r <- initial1

@@ -264,11 +264,11 @@ groupIOVecsOf n maxIOVLen (D.Stream step state) =

264 step' gst (GatherInitial st) = do

265 when (n <= 0) $

266 -- XXX we can pass the module string from the higher level API

267− error $ "Streamly.Internal.Data.Array.Foreign.Mut.Types.groupIOVecsOf: the size of "

267+ error $ "Streamly.Internal.Data.Array.Foreign.Mut.Type.groupIOVecsOf: the size of "

268 ++ "groups [" ++ show n ++ "] must be a natural number"

269 when (maxIOVLen <= 0) $

270 -- XXX we can pass the module string from the higher level API

271− error $ "Streamly.Internal.Data.Array.Foreign.Mut.Types.groupIOVecsOf: the number of "

271+ error $ "Streamly.Internal.Data.Array.Foreign.Mut.Type.groupIOVecsOf: the number of "

272 ++ "IOVec entries [" ++ show n ++ "] must be a natural number"

273 r <- step (adaptState gst) st

274 case r of

src/Streamly/Internal/Data/Binary/Decode.hs+1−1

@@ -35,7 +35,7 @@ import Streamly.Internal.Data.Tuple.Strict (Tuple' (..))

35import qualified Streamly.Internal.Data.Array.Foreign as A

36import qualified Streamly.Internal.Data.Parser as PR

37import qualified Streamly.Internal.Data.Parser.ParserD as PRD

38−import qualified Streamly.Internal.Data.Parser.ParserK.Types as PRK

38+import qualified Streamly.Internal.Data.Parser.ParserK.Type as PRK

39

40-- | A value of type '()' is encoded as @0@ in binary encoding.

41--

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

@@ -229,12 +229,12 @@ import Data.Semigroup (Semigroup((<>)))

229import Streamly.Internal.Data.Either.Strict

230 (Either'(..), fromLeft', fromRight', isLeft', isRight')

231import Streamly.Internal.Data.Maybe.Strict (Maybe'(..), toMaybe)

232−import Streamly.Internal.Data.Pipe.Types (Pipe (..), PipeState(..))

232+import Streamly.Internal.Data.Pipe.Type (Pipe (..), PipeState(..))

233import Streamly.Internal.Data.Tuple.Strict (Tuple'(..), Tuple3'(..))

234import Streamly.Internal.Data.Stream.Serial (SerialT)

235

236import qualified Data.Map.Strict as Map

237−import qualified Streamly.Internal.Data.Pipe.Types as Pipe

237+import qualified Streamly.Internal.Data.Pipe.Type as Pipe

238import qualified Streamly.Internal.Data.Stream.IsStream.Enumeration as Stream

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

240import qualified Prelude

@@ -246,7 +246,7 @@ import Prelude hiding

246 , reverse, iterate, init, and, or, lookup, (!!)

247 , scanl, scanl1, replicate, concatMap, mconcat, foldMap, unzip

248 , span, splitAt, break, mapM, zip)

249−import Streamly.Internal.Data.Fold.Types

249+import Streamly.Internal.Data.Fold.Type

250

251-- $setup

252-- >>> :m

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

@@ -18,9 +18,9 @@ import Data.Coerce (coerce)

18#if __GLASGOW_HASKELL__ < 808

19import Data.Semigroup (Semigroup(..))

20#endif

21−import Streamly.Internal.Data.Fold.Types (Fold)

21+import Streamly.Internal.Data.Fold.Type (Fold)

22

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

23+import qualified Streamly.Internal.Data.Fold.Type as Fold

24

25-- | The type @Tee m a b@ represents a left fold over an input stream of values

26-- of type @a@ to a single value of type @b@ in 'Monad' @m@.

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

@@ -1,5 +1,5 @@

1-- |

2−-- Module : Streamly.Internal.Data.Fold.Types

2+-- Module : Streamly.Internal.Data.Fold.Type

5-- License : BSD3

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

165-- then be used only for the case when the stream stops before the fold

166-- completes.

167

168−module Streamly.Internal.Data.Fold.Types

168+module Streamly.Internal.Data.Fold.Type

169 (

170 -- * Types

171 Step (..)

src/Streamly/Internal/Data/Parser.hs+4−4

@@ -199,12 +199,12 @@ import Control.Monad.Catch (MonadCatch)

199import Prelude

200 hiding (any, all, take, takeWhile, sequence, concatMap, maybe, either)

201

202−import Streamly.Internal.Data.Fold.Types (Fold(..))

202+import Streamly.Internal.Data.Fold.Type (Fold(..))

203−import Streamly.Internal.Data.Parser.ParserK.Types (Parser)

203+import Streamly.Internal.Data.Parser.ParserK.Type (Parser)

204

205−import qualified Streamly.Internal.Data.Fold.Types as FL

205+import qualified Streamly.Internal.Data.Fold.Type as FL

206import qualified Streamly.Internal.Data.Parser.ParserD as D

207−import qualified Streamly.Internal.Data.Parser.ParserK.Types as K

207+import qualified Streamly.Internal.Data.Parser.ParserK.Type as K

208

209--

210-- $setup

src/Streamly/Internal/Data/Parser/ParserD.hs+3−3

@@ -163,15 +163,15 @@ where

163import Control.Exception (assert)

164import Control.Monad.Catch (MonadCatch, MonadThrow(..))

165import Fusion.Plugin.Types (Fuse(..))

166−import Streamly.Internal.Data.Fold.Types (Fold(..))

166+import Streamly.Internal.Data.Fold.Type (Fold(..))

167import Streamly.Internal.Data.Tuple.Strict (Tuple'(..))

168

169−import qualified Streamly.Internal.Data.Fold.Types as FL

169+import qualified Streamly.Internal.Data.Fold.Type as FL

170

171import Prelude hiding

172 (any, all, take, takeWhile, sequence, concatMap, maybe, either, span)

173import Streamly.Internal.Data.Parser.ParserD.Tee

174−import Streamly.Internal.Data.Parser.ParserD.Types

174+import Streamly.Internal.Data.Parser.ParserD.Type

175

176--

177-- $setup

src/Streamly/Internal/Data/Parser/ParserD/Tee.hs+1−1

@@ -43,7 +43,7 @@ import Prelude

43 hiding (any, all, takeWhile)

44

45import Fusion.Plugin.Types (Fuse(..))

46−import Streamly.Internal.Data.Parser.ParserD.Types

46+import Streamly.Internal.Data.Parser.ParserD.Type

47 (Initial(..), Parser(..), Step(..), ParseError)

48

49-------------------------------------------------------------------------------

src/Streamly/Internal/Data/Parser/ParserD/Types.hs → src/Streamly/Internal/Data/Parser/ParserD/Type.hsrenamed+7−7

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

1#include "inline.hs"

2

3-- |

4−-- Module : Streamly.Internal.Data.Parser.ParserD.Types

4+-- Module : Streamly.Internal.Data.Parser.ParserD.Type

6-- License : BSD-3-Clause

7-- Maintainer : streamly@composewell.com

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

11-- Streaming and backtracking parsers.

12--

13-- Parsers just extend folds. Please read the 'Fold' design notes in

14−-- "Streamly.Internal.Data.Fold.Types" for background on the design.

14+-- "Streamly.Internal.Data.Fold.Type" for background on the design.

15--

16-- = Parser Design

17--

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

109-- merge the resulting streams using different merge strategies (e.g.

110-- interleaving or serial).

111

112−module Streamly.Internal.Data.Parser.ParserD.Types

112+module Streamly.Internal.Data.Parser.ParserD.Type

113 (

114 Initial (..)

115 , Step (..)

@@ -138,10 +138,10 @@ import Control.Monad (MonadPlus(..))

138import Control.Monad.Catch (MonadCatch, try, throwM, MonadThrow)

139import Data.Bifunctor (Bifunctor(..))

140import Fusion.Plugin.Types (Fuse(..))

141−import Streamly.Internal.Data.Fold.Types (Fold(..), toList)

141+import Streamly.Internal.Data.Fold.Type (Fold(..), toList)

142import Streamly.Internal.Data.Tuple.Strict (Tuple3'(..))

143

144−import qualified Streamly.Internal.Data.Fold.Types as FL

144+import qualified Streamly.Internal.Data.Fold.Type as FL

145

146import Prelude hiding (concatMap)

147--

@@ -864,7 +864,7 @@ concatMap func (Parser stepL initialL extractL) = Parser step initial extract

864-- for small number of compositions but for a scalable implementation we need a

865-- CPS version.

866

867−-- | See documentation of 'Streamly.Internal.Data.Parser.ParserK.Types.Parser'.

867+-- | See documentation of 'Streamly.Internal.Data.Parser.ParserK.Type.Parser'.

868--

869instance MonadThrow m => Monad (Parser m a) where

870 {-# INLINE return #-}

@@ -873,7 +873,7 @@ instance MonadThrow m => Monad (Parser m a) where

873 {-# INLINE (>>=) #-}

874 (>>=) = flip concatMap

875

876−-- | See documentation of 'Streamly.Internal.Data.Parser.ParserK.Types.Parser'.

876+-- | See documentation of 'Streamly.Internal.Data.Parser.ParserK.Type.Parser'.

877--

878instance MonadCatch m => MonadPlus (Parser m a) where

879 {-# INLINE mzero #-}

src/Streamly/Internal/Data/Parser/ParserK/Types.hs → src/Streamly/Internal/Data/Parser/ParserK/Type.hsrenamed+3−3

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

1#include "inline.hs"

2

3-- |

4−-- Module : Streamly.Internal.Data.Parser.ParserK.Types

4+-- Module : Streamly.Internal.Data.Parser.ParserK.Type

6-- License : BSD-3-Clause

7-- Maintainer : streamly@composewell.com

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

18-- The direct style representation does not allow for recursive definitions of

19-- "some" and "many" whereas CPS allows that.

20

21−module Streamly.Internal.Data.Parser.ParserK.Types

21+module Streamly.Internal.Data.Parser.ParserK.Type

22 (

23 Parser (..)

24 , yield

@@ -43,7 +43,7 @@ import Data.Semigroup ((<>))

43#endif

44import Streamly.Internal.Control.Exception

45

46−import qualified Streamly.Internal.Data.Parser.ParserD.Types as D

46+import qualified Streamly.Internal.Data.Parser.ParserD.Type as D

47

48-- | The parse driver result. The driver may stop with a final result, pause

49-- with a continuation to resume, or fail with an error.

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

@@ -244,9 +244,9 @@ import Prelude

244

245-- import Streamly.Prelude (MonadAsync, parallel)

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

247−import Streamly.Internal.Data.Pipe.Types

247+import Streamly.Internal.Data.Pipe.Type

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

249−-- import Streamly.Internal.Data.Array.Foreign.Types (Array)

249+-- import Streamly.Internal.Data.Array.Foreign.Type (Array)

250-- import Streamly.Internal.Ring.Foreign (Ring)

251-- import Streamly.Internal.Data.Stream.Serial (SerialT)

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

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

256

257-- import Streamly.Internal.Data.Strict

258

259−-- import qualified Streamly.Internal.Data.Array.Foreign.Types as A

259+-- import qualified Streamly.Internal.Data.Array.Foreign.Type as A

260-- import qualified Streamly.Prelude as S

261-- import qualified Streamly.Internal.Data.Stream.StreamD as D

262-- import qualified Streamly.Internal.Data.Stream.StreamK as K

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

@@ -1,14 +1,14 @@

1#include "inline.hs"

2

3-- |

4−-- Module : Streamly.Internal.Data.Pipe.Types

4+-- Module : Streamly.Internal.Data.Pipe.Type

6-- License : BSD3

7-- Maintainer : streamly@composewell.com

8-- Stability : experimental

9-- Portability : GHC

10

11−module Streamly.Internal.Data.Pipe.Types

11+module Streamly.Internal.Data.Pipe.Type

12 ( Step (..)

13 , Pipe (..)

14 , PipeState (..)

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

@@ -47,7 +47,7 @@ where

47import Streamly.Internal.Data.Stream.StreamD.Step (Step(..))

48import Streamly.Internal.Data.Stream.StreamD.Type (Stream(..))

49import Streamly.Internal.Data.SVar (defState)

50−import Streamly.Internal.Data.Unfold.Types (Unfold(..))

50+import Streamly.Internal.Data.Unfold.Type (Unfold(..))

51

52import Streamly.Internal.Data.Producer.Type

53import Prelude hiding (concat)

src/Streamly/Internal/Data/Producer/Source.hs+1−1

@@ -42,7 +42,7 @@ import Streamly.Internal.Data.Producer.Type (Producer(..))

42import Streamly.Internal.Data.Stream.StreamD.Step (Step(..))

43

44import qualified Streamly.Internal.Data.Parser.ParserD as ParserD

45−import qualified Streamly.Internal.Data.Parser.ParserK.Types as ParserK

45+import qualified Streamly.Internal.Data.Parser.ParserK.Type as ParserK

46

47import Prelude hiding (read)

48

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

@@ -66,8 +66,8 @@ import Prelude

66 reverse, iterate, init, and, or, lookup, foldr1, (!!),

67 scanl, scanl1, replicate, concatMap, mconcat, foldMap, unzip)

68

69−import Streamly.Internal.Data.Fold.Types (Fold(..), Step(..))

69+import Streamly.Internal.Data.Fold.Type (Fold(..), Step(..))

70−import Streamly.Internal.Data.Sink.Types (Sink(..))

70+import Streamly.Internal.Data.Sink.Type (Sink(..))

71

72import qualified Data.Map.Strict as Map

73

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

@@ -1,12 +1,12 @@

1-- |

2−-- Module : Streamly.Internal.Data.Sink.Types

2+-- Module : Streamly.Internal.Data.Sink.Type

4-- License : BSD3

5-- Maintainer : streamly@composewell.com

6-- Stability : experimental

7-- Portability : GHC

8

9−module Streamly.Internal.Data.Sink.Types

9+module Streamly.Internal.Data.Sink.Type

10 (

11 Sink (..)

12 )

src/Streamly/Internal/Data/SmallArray.hs+4−4

@@ -48,16 +48,16 @@ import Control.Monad.IO.Class (MonadIO, liftIO)

48import GHC.IO (unsafePerformIO)

49import Data.Functor.Identity (runIdentity)

50

51−import Streamly.Internal.Data.SmallArray.Types

51+import Streamly.Internal.Data.SmallArray.Type

52

53import Streamly.Internal.Data.Tuple.Strict (Tuple'(..))

54−import Streamly.Internal.Data.Unfold.Types (Unfold(..))

54+import Streamly.Internal.Data.Unfold.Type (Unfold(..))

55−import Streamly.Internal.Data.Fold.Types (Fold(..))

55+import Streamly.Internal.Data.Fold.Type (Fold(..))

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

57import Streamly.Internal.Data.Stream.Serial (SerialT)

58

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

60−import qualified Streamly.Internal.Data.Fold.Types as FL

60+import qualified Streamly.Internal.Data.Fold.Type as FL

61

62{-# NOINLINE bottomElement #-}

63bottomElement :: a

src/Streamly/Internal/Data/SmallArray/Types.hs → src/Streamly/Internal/Data/SmallArray/Type.hsrenamed+1−1

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

28-- The underlying type, 'SmallArray#', was introduced in GHC 7.10, so prior to

29-- that version, this module simply implements small arrays as 'Array'.

30

31−module Streamly.Internal.Data.SmallArray.Types

31+module Streamly.Internal.Data.SmallArray.Type

32 ( SmallArray(..)

33 , SmallMutableArray(..)

34 , newSmallArray

src/Streamly/Internal/Data/Stream/IsStream/Common.hs+2−2

@@ -50,8 +50,8 @@ where

50import Control.Concurrent (threadDelay)

51import Control.Monad.IO.Class (MonadIO(..))

52import Foreign.Storable (Storable)

53−import Streamly.Internal.Data.Array.Foreign.Types (Array)

53+import Streamly.Internal.Data.Array.Foreign.Type (Array)

54−import Streamly.Internal.Data.Fold.Types (Fold (..))

54+import Streamly.Internal.Data.Fold.Type (Fold (..))

55import Streamly.Internal.Data.Stream.IsStream.Combinators (maxYields)

56import Streamly.Internal.Data.Stream.Prelude (fromStreamS, toStreamS)

57import Streamly.Internal.Data.Stream.Serial (SerialT)

src/Streamly/Internal/Data/Stream/IsStream/Eliminate.hs+2−2

@@ -156,14 +156,14 @@ import Streamly.Internal.Data.Stream.StreamD (fromStreamD, toStreamD)

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

157import Streamly.Internal.Data.Stream.Serial (SerialT)

158

159−import qualified Streamly.Internal.Data.Array.Foreign.Types as A

159+import qualified Streamly.Internal.Data.Array.Foreign.Type as A

160import qualified Streamly.Internal.Data.Fold as FL

161import qualified Streamly.Internal.Data.Stream.Parallel as Par

162import qualified Streamly.Internal.Data.Stream.Prelude as P

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

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

165import qualified Streamly.Internal.Data.Parser.ParserD as PRD

166−import qualified Streamly.Internal.Data.Parser.ParserK.Types as PRK

166+import qualified Streamly.Internal.Data.Parser.ParserK.Type as PRK

167import qualified System.IO as IO

168#ifdef USE_STREAMK_ONLY

169import qualified Streamly.Internal.Data.Stream.StreamK as S

src/Streamly/Internal/Data/Stream/IsStream/Generate.hs+1−1

@@ -89,7 +89,7 @@ where

89

90import Control.Monad.IO.Class (MonadIO(..))

91import Data.Void (Void)

92−import Streamly.Internal.Data.Unfold.Types (Unfold)

92+import Streamly.Internal.Data.Unfold.Type (Unfold)

93import Streamly.Internal.Data.SVar (MonadAsync, Rate (..))

94import Streamly.Internal.Data.Stream.IsStream.Enumeration

95 (Enumerable(..), enumerate, enumerateTo)

src/Streamly/Internal/Data/Stream/IsStream/Nesting.hs+5−5

@@ -252,10 +252,10 @@ import Data.Heap (Entry(..))

252import Data.Kind (Type)

253import Data.Maybe (isNothing)

254import Foreign.Storable (Storable)

255−import Streamly.Internal.Data.Fold.Types (Fold (..), Fold2 (..))

255+import Streamly.Internal.Data.Fold.Type (Fold (..), Fold2 (..))

256import Streamly.Internal.Data.Parser (Parser (..))

257−import Streamly.Internal.Data.Unfold.Types (Unfold)

257+import Streamly.Internal.Data.Unfold.Type (Unfold)

258−import Streamly.Internal.Data.Array.Foreign.Types (Array)

258+import Streamly.Internal.Data.Array.Foreign.Type (Array)

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

260import Streamly.Internal.Data.Stream.Ahead (ahead)

261import Streamly.Internal.Data.Stream.Async (async, wAsync)

@@ -285,9 +285,9 @@ import Streamly.Internal.Data.Tuple.Strict (Tuple'(..))

285

286import qualified Data.Heap as H

287import qualified Data.Map.Strict as Map

288−import qualified Streamly.Internal.Data.Array.Foreign.Types as A

288+import qualified Streamly.Internal.Data.Array.Foreign.Type as A

289import qualified Streamly.Internal.Data.Fold as FL

290−import qualified Streamly.Internal.Data.Parser.ParserK.Types as PRK

290+import qualified Streamly.Internal.Data.Parser.ParserK.Type as PRK

291import qualified Streamly.Internal.Data.Parser.ParserD as PRD

292import qualified Streamly.Internal.Data.Stream.Parallel as Par

293import qualified Streamly.Internal.Data.Stream.Serial as Serial

src/Streamly/Internal/Data/Stream/IsStream/Transform.hs+2−2

@@ -216,8 +216,8 @@ import Data.Either (isLeft, isRight)

216import Data.Kind (Type)

217import Data.Maybe (isJust, fromJust)

218import Streamly.Internal.BaseCompat (fromLeft, fromRight)

219−import Streamly.Internal.Data.Fold.Types (Fold (..))

219+import Streamly.Internal.Data.Fold.Type (Fold (..))

220−import Streamly.Internal.Data.Pipe.Types (Pipe (..))

220+import Streamly.Internal.Data.Pipe.Type (Pipe (..))

221import Streamly.Internal.Data.Stream.IsStream.Combinators

222 ( inspectMode, maxBuffer, maxThreads, rate, avgRate, minRate

223 , maxRate, constRate)

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

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

58

59import qualified Data.Set as Set

60

61−import Streamly.Internal.Data.Fold.Types (Fold)

61+import Streamly.Internal.Data.Fold.Type (Fold)

62import Streamly.Internal.Data.Stream.StreamD.Type (Step(..))

63import Streamly.Internal.Data.Stream.StreamK

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

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

@@ -69,7 +69,7 @@ import Control.Monad.Trans.Class (MonadTrans(..))

69import Prelude hiding (foldr, minimum, maximum)

70import qualified Prelude

71

72−import Streamly.Internal.Data.Fold.Types (Fold (..))

72+import Streamly.Internal.Data.Fold.Type (Fold (..))

73

74#ifdef USE_STREAMK_ONLY

75import qualified Streamly.Internal.Data.Stream.StreamK as S

src/Streamly/Internal/Data/Stream/SVar.hs+2−2

@@ -49,11 +49,11 @@ import Control.Monad.IO.Class (MonadIO(liftIO))

49import Data.IORef (newIORef, readIORef, mkWeakIORef, writeIORef)

50import Data.Maybe (isNothing)

51import Streamly.Internal.Data.Atomics (atomicModifyIORefCAS_)

52−import Streamly.Internal.Data.Fold.Types (Fold(..))

52+import Streamly.Internal.Data.Fold.Type (Fold(..))

53import Streamly.Internal.Data.Time.Clock (Clock(Monotonic), getTime)

54import System.Mem (performMajorGC)

55

56−import qualified Streamly.Internal.Data.Fold.Types as FL

56+import qualified Streamly.Internal.Data.Fold.Type as FL

57import qualified Streamly.Internal.Data.Stream.StreamD.Type as D

58import qualified Streamly.Internal.Data.Stream.StreamK.Type as K

59

src/Streamly/Internal/Data/Stream/StreamD/Nesting.hs+5−5

@@ -157,13 +157,13 @@ import Foreign.Storable (Storable(..))

157import Fusion.Plugin.Types (Fuse(..))

158import GHC.Types (SPEC(..))

159

160−import Streamly.Internal.Data.Array.Foreign.Types (Array(..))

160+import Streamly.Internal.Data.Array.Foreign.Type (Array(..))

161−import Streamly.Internal.Data.Fold.Types (Fold(..))

161+import Streamly.Internal.Data.Fold.Type (Fold(..))

162import Streamly.Internal.Data.Parser (ParseError(..))

163−import Streamly.Internal.Data.Unfold.Types (Unfold(..))

163+import Streamly.Internal.Data.Unfold.Type (Unfold(..))

164

165−import qualified Streamly.Internal.Data.Array.Foreign.Types as A

165+import qualified Streamly.Internal.Data.Array.Foreign.Type as A

166−import qualified Streamly.Internal.Data.Fold.Types as FL

166+import qualified Streamly.Internal.Data.Fold.Type as FL

167import qualified Streamly.Internal.Data.Parser as PR

168import qualified Streamly.Internal.Data.Parser.ParserD as PRD

169import qualified Streamly.Internal.Ring.Foreign as RB

src/Streamly/Internal/Data/Stream/StreamD/Transform.hs+5−5

@@ -133,16 +133,16 @@ import Foreign.Storable (Storable(..))

133import GHC.Types (SPEC(..))

134import qualified Control.Monad.Catch as MC

135

136−import Streamly.Internal.Data.Fold.Types (Fold(..))

136+import Streamly.Internal.Data.Fold.Type (Fold(..))

137−import Streamly.Internal.Data.Pipe.Types (Pipe(..), PipeState(..))

137+import Streamly.Internal.Data.Pipe.Type (Pipe(..), PipeState(..))

138import Streamly.Internal.Data.Time.Clock (Clock(Monotonic), getTime)

139import Streamly.Internal.Data.Time.Units

140 (TimeUnit64, toRelTime64, diffAbsTime64)

141

142−import qualified Streamly.Internal.Data.Array.Foreign.Types as A

142+import qualified Streamly.Internal.Data.Array.Foreign.Type as A

143−import qualified Streamly.Internal.Data.Fold.Types as FL

143+import qualified Streamly.Internal.Data.Fold.Type as FL

144import qualified Streamly.Internal.Data.IORef.Prim as Prim

145−import qualified Streamly.Internal.Data.Pipe.Types as Pipe

145+import qualified Streamly.Internal.Data.Pipe.Type as Pipe

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

147

148import Prelude hiding

src/Streamly/Internal/Data/Stream/StreamD/Type.hs+3−3

@@ -96,12 +96,12 @@ import GHC.Base (build)

96import GHC.Types (SPEC(..))

97import Prelude hiding (map, mapM, foldr, take, concatMap, takeWhile)

98

99−import Streamly.Internal.Data.Fold.Types (Fold(..), Fold2(..))

99+import Streamly.Internal.Data.Fold.Type (Fold(..), Fold2(..))

100import Streamly.Internal.Data.Stream.StreamD.Step (Step (..))

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

102−import Streamly.Internal.Data.Unfold.Types (Unfold(..))

102+import Streamly.Internal.Data.Unfold.Type (Unfold(..))

103

104−import qualified Streamly.Internal.Data.Fold.Types as FL

104+import qualified Streamly.Internal.Data.Fold.Type as FL

105import qualified Streamly.Internal.Data.Stream.StreamK.Type as K

106

107------------------------------------------------------------------------------

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

@@ -200,7 +200,7 @@ import qualified Prelude

200import Streamly.Internal.Data.SVar

201import Streamly.Internal.Data.Stream.StreamK.Type

202

203−import qualified Streamly.Internal.Data.Fold.Types as FL

203+import qualified Streamly.Internal.Data.Fold.Type as FL

204

205-- $setup

206-- >>> :m

src/Streamly/Internal/Data/Unfold.hs+3−3

@@ -178,7 +178,7 @@ import Data.IORef (newIORef, readIORef, mkWeakIORef, writeIORef)

178import Data.Maybe (isNothing)

179import Data.Void (Void)

180import GHC.Types (SPEC(..))

181−import Streamly.Internal.Data.Fold.Types (Fold(..))

181+import Streamly.Internal.Data.Fold.Type (Fold(..))

182import Streamly.Internal.Data.IOFinalizer

183 (newIOFinalizer, runIOFinalizer, clearingIOFinalizer)

184import Streamly.Internal.Data.Stream.StreamD.Type (Stream(..), Step(..))

@@ -188,13 +188,13 @@ import System.Mem (performMajorGC)

188import qualified Prelude

189import qualified Control.Monad.Catch as MC

190import qualified Data.Tuple as Tuple

191−import qualified Streamly.Internal.Data.Fold.Types as FL

191+import qualified Streamly.Internal.Data.Fold.Type as FL

192import qualified Streamly.Internal.Data.Stream.StreamD.Type as D

193import qualified Streamly.Internal.Data.Stream.StreamK as K (uncons)

194import qualified Streamly.Internal.Data.Stream.StreamK.Type as K

195

196import Streamly.Internal.Data.SVar

197−import Streamly.Internal.Data.Unfold.Types

197+import Streamly.Internal.Data.Unfold.Type

198import Prelude

199 hiding (concat, map, mapM, takeWhile, take, filter, const, zipWith

200 , drop, dropWhile)

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

@@ -1,12 +1,12 @@

1-- |

2−-- Module : Streamly.Internal.Data.Unfold.Types

2+-- Module : Streamly.Internal.Data.Unfold.Type

4-- License : BSD3

5-- Maintainer : streamly@composewell.com

6-- Stability : experimental

7-- Portability : GHC

8

9−module Streamly.Internal.Data.Unfold.Types

9+module Streamly.Internal.Data.Unfold.Type

10 ( Unfold (..)

11 , singletonM

12 , singleton

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

@@ -63,8 +63,8 @@ import Prelude hiding (read)

63

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

65import Streamly.Internal.BaseCompat (fromLeft, fromRight)

66−import Streamly.Internal.Data.Unfold.Types (Unfold(..))

66+import Streamly.Internal.Data.Unfold.Type (Unfold(..))

67−-- import Streamly.Internal.Data.Array.Foreign.Types

67+-- import Streamly.Internal.Data.Array.Foreign.Type

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

69-- lpackArraysChunksOf)

70-- import Streamly.Internal.Data.Stream.Serial (SerialT)

@@ -72,7 +72,7 @@ import Streamly.Internal.Data.Stream.StreamK.Type (IsStream)

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

73

74-- import qualified Streamly.Data.Fold as FL

75−-- import qualified Streamly.Internal.Data.Fold.Types as FL

75+-- import qualified Streamly.Internal.Data.Fold.Type as FL

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

77-- import qualified Streamly.Internal.Data.Array.Stream.Foreign as AS

78import qualified Streamly.Internal.Data.Stream.IsStream as S

@@ -166,9 +166,9 @@ toChunks = toChunksWithBufferOf defaultChunkSize

166

167-- | Unfolds a handle into a stream of 'Word8' arrays. Requests to the IO

168-- device are performed using a buffer of size

169−-- 'Streamly.Internal.Data.Array.Foreign.Types.defaultChunkSize'. The

169+-- 'Streamly.Internal.Data.Array.Foreign.Type.defaultChunkSize'. The

170-- size of arrays in the resulting stream are therefore less than or equal to

171−-- 'Streamly.Internal.Data.Array.Foreign.Types.defaultChunkSize'.

171+-- 'Streamly.Internal.Data.Array.Foreign.Type.defaultChunkSize'.

172--

173-- @since 0.7.0

174{-# INLINE readChunks #-}

@@ -343,7 +343,7 @@ fromStreamWithBufferOf n h m = fromChunks h $ S.arraysOf n m

343-- > write = 'writeWithBufferOf' A.defaultChunkSize

344--

345-- | Write a byte stream to a file handle. Accumulates the input in chunks of

346−-- up to 'Streamly.Internal.Data.Array.Foreign.Types.defaultChunkSize' before writing.

346+-- up to 'Streamly.Internal.Data.Array.Foreign.Type.defaultChunkSize' before writing.

347--

348-- NOTE: This may perform better than the 'write' fold, you can try this if you

349-- need some extra perf boost.

@@ -393,7 +393,7 @@ writeWithBufferOf n h = FL.chunksOf n (writeNUnsafe n) (writeChunks h)

393-- > write = 'writeWithBufferOf' A.defaultChunkSize

394--

395-- | Write a byte stream to a file handle. Accumulates the input in chunks of

396−-- up to 'Streamly.Internal.Data.Array.Foreign.Types.defaultChunkSize' before writing

396+-- up to 'Streamly.Internal.Data.Array.Foreign.Type.defaultChunkSize' before writing

397-- to the IO device.

398--

399-- @since 0.7.0

src/Streamly/Internal/FileSystem/Event/Darwin.hs+1−1

@@ -165,7 +165,7 @@ import GHC.IO.Handle.FD (fdToHandle)

165import Streamly.Prelude (SerialT)

166import Streamly.Internal.Data.Cont (contListMap)

167import Streamly.Internal.Data.Parser (Parser)

168−import Streamly.Internal.Data.Array.Foreign.Types (Array(..))

168+import Streamly.Internal.Data.Array.Foreign.Type (Array(..))

169import System.IO (Handle, hClose)

170

171import qualified Data.List.NonEmpty as NonEmpty

src/Streamly/Internal/FileSystem/Event/Linux.hs+1−1

@@ -171,7 +171,7 @@ import GHC.IO.FD (fdFD, mkFD)

171import GHC.IO.Handle.FD (mkHandleFromFD)

172import Streamly.Prelude (SerialT)

173import Streamly.Internal.Data.Parser (Parser)

174−import Streamly.Internal.Data.Array.Foreign.Types (Array(..))

174+import Streamly.Internal.Data.Array.Foreign.Type (Array(..))

175import System.IO (Handle, hClose, IOMode(ReadMode))

176#if !MIN_VERSION_base(4,10,0)

177import Control.Concurrent.MVar (readMVar)

src/Streamly/Internal/FileSystem/FD.hs+2−2

@@ -130,8 +130,8 @@ import Prelude hiding (read)

130import qualified GHC.IO.FD as FD

131import qualified GHC.IO.Device as RawIO

132

133−import Streamly.Internal.Data.Array.Foreign.Types (Array(..), byteLength, defaultChunkSize, unsafeFreeze)

133+import Streamly.Internal.Data.Array.Foreign.Type (Array(..), byteLength, defaultChunkSize, unsafeFreeze)

134−import Streamly.Internal.Data.Array.Foreign.Mut.Types (mutableArray)

134+import Streamly.Internal.Data.Array.Foreign.Mut.Type (mutableArray)

135

136import Streamly.Internal.Data.Stream.Serial (SerialT)

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

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

@@ -94,9 +94,9 @@ import Prelude hiding (read)

94import qualified Control.Monad.Catch as MC

95import qualified System.IO as SIO

96

97−import Streamly.Internal.Data.Fold.Types (Fold(..))

97+import Streamly.Internal.Data.Fold.Type (Fold(..))

98−import Streamly.Internal.Data.Unfold.Types (Unfold(..))

98+import Streamly.Internal.Data.Unfold.Type (Unfold(..))

99−import Streamly.Internal.Data.Array.Foreign.Types

99+import Streamly.Internal.Data.Array.Foreign.Type

100 (Array(..), defaultChunkSize, writeNUnsafe)

101import Streamly.Internal.Data.Stream.Serial (SerialT)

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

@@ -104,7 +104,7 @@ import Streamly.Internal.Data.SVar (MonadAsync)

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

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

106

107−import qualified Streamly.Internal.Data.Fold.Types as FL

107+import qualified Streamly.Internal.Data.Fold.Type as FL

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

109import qualified Streamly.Internal.FileSystem.Handle as FH

110import qualified Streamly.Internal.Data.Array.Stream.Foreign as AS

@@ -243,9 +243,9 @@ readChunksWithBufferOf = usingFile2 FH.readChunksWithBufferOf

243

244-- | Unfolds a 'FilePath' into a stream of 'Word8' arrays. Requests to the IO

245-- device are performed using a buffer of size

246−-- 'Streamly.Internal.Data.Array.Foreign.Types.defaultChunkSize'. The

246+-- 'Streamly.Internal.Data.Array.Foreign.Type.defaultChunkSize'. The

247-- size of arrays in the resulting stream are therefore less than or equal to

248−-- 'Streamly.Internal.Data.Array.Foreign.Types.defaultChunkSize'.

248+-- 'Streamly.Internal.Data.Array.Foreign.Type.defaultChunkSize'.

249--

250-- /Pre-release/

251{-# INLINE readChunks #-}

@@ -262,7 +262,7 @@ readWithBufferOf = usingFile2 FH.readWithBufferOf

262

263-- | Unfolds a file path into a byte stream. IO requests to the device are

264-- performed in sizes of

265−-- 'Streamly.Internal.Data.Array.Foreign.Types.defaultChunkSize'.

265+-- 'Streamly.Internal.Data.Array.Foreign.Type.defaultChunkSize'.

266--

267-- @since 0.7.0

268{-# INLINE read #-}

@@ -382,7 +382,7 @@ writeWithBufferOf n path =

382-- > write = 'writeWithBufferOf' A.defaultChunkSize

383--

384-- | Write a byte stream to a file. Accumulates the input in chunks of up to

385−-- 'Streamly.Internal.Data.Array.Foreign.Types.defaultChunkSize' before writing to

385+-- 'Streamly.Internal.Data.Array.Foreign.Type.defaultChunkSize' before writing to

386-- the IO device.

387--

388-- /Pre-release/

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

@@ -111,18 +111,18 @@ import Prelude hiding (read)

111

112import Streamly.Prelude (MonadAsync)

113import Streamly.Data.Fold (Fold)

114−import Streamly.Internal.Data.Fold.Types (Fold2(..))

114+import Streamly.Internal.Data.Fold.Type (Fold2(..))

115−import Streamly.Internal.Data.Unfold.Types (Unfold(..))

115+import Streamly.Internal.Data.Unfold.Type (Unfold(..))

116−import Streamly.Internal.Data.Array.Foreign.Types

116+import Streamly.Internal.Data.Array.Foreign.Type

117 (Array(..), writeNUnsafe, defaultChunkSize , unsafeFreezeWithShrink)

118−import Streamly.Internal.Data.Array.Foreign.Mut.Types (mutableArray)

118+import Streamly.Internal.Data.Array.Foreign.Mut.Type (mutableArray)

119import Streamly.Internal.Data.Stream.Serial (SerialT)

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

121import Streamly.Internal.Data.Array.Stream.Foreign (lpackArraysChunksOf)

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

123

124import qualified Streamly.Data.Fold as FL

125−import qualified Streamly.Internal.Data.Fold.Types as FL

125+import qualified Streamly.Internal.Data.Fold.Type as FL

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

127import qualified Streamly.Internal.Data.Array.Foreign as IA

128import qualified Streamly.Internal.Data.Array.Stream.Foreign as AS

@@ -255,9 +255,9 @@ getBytes = toBytes stdin

255

256-- | Unfolds a handle into a stream of 'Word8' arrays. Requests to the IO

257-- device are performed using a buffer of size

258−-- 'Streamly.Internal.Data.Array.Foreign.Types.defaultChunkSize'. The

258+-- 'Streamly.Internal.Data.Array.Foreign.Type.defaultChunkSize'. The

259-- size of arrays in the resulting stream are therefore less than or equal to

260−-- 'Streamly.Internal.Data.Array.Foreign.Types.defaultChunkSize'.

260+-- 'Streamly.Internal.Data.Array.Foreign.Type.defaultChunkSize'.

261--

262-- @since 0.7.0

263{-# INLINE readChunks #-}

@@ -294,7 +294,7 @@ toBytesWithBufferOf chunkSize h = AS.concat $ toChunksWithBufferOf chunkSize h

294--

295-- | Unfolds a file handle into a byte stream. IO requests to the device are

296-- performed in sizes of

297−-- 'Streamly.Internal.Data.Array.Foreign.Types.defaultChunkSize'.

297+-- 'Streamly.Internal.Data.Array.Foreign.Type.defaultChunkSize'.

298--

299-- @since 0.7.0

300{-# INLINE read #-}

@@ -411,7 +411,7 @@ fromBytesWithBufferOf n h m = fromChunks h $ S.arraysOf n m

411-- > write = 'writeWithBufferOf' A.defaultChunkSize

412--

413-- | Write a byte stream to a file handle. Accumulates the input in chunks of

414−-- up to 'Streamly.Internal.Data.Array.Foreign.Types.defaultChunkSize' before writing.

414+-- up to 'Streamly.Internal.Data.Array.Foreign.Type.defaultChunkSize' before writing.

415--

416-- NOTE: This may perform better than the 'write' fold, you can try this if you

417-- need some extra perf boost.

@@ -469,7 +469,7 @@ writeWithBufferOf2 n = FL.chunksOf2 n (writeNUnsafe n) writeChunks2

469-- > write = 'writeWithBufferOf' A.defaultChunkSize

470--

471-- | Write a byte stream to a file handle. Accumulates the input in chunks of

472−-- up to 'Streamly.Internal.Data.Array.Foreign.Types.defaultChunkSize' before writing

472+-- up to 'Streamly.Internal.Data.Array.Foreign.Type.defaultChunkSize' before writing

473-- to the IO device.

474--

475-- @since 0.7.0

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

@@ -103,13 +103,13 @@ import Network.Socket

103 socket)

104import Prelude hiding (read)

105

106−import Streamly.Internal.Data.Array.Foreign.Types (Array(..), defaultChunkSize, writeNUnsafe)

106+import Streamly.Internal.Data.Array.Foreign.Type (Array(..), defaultChunkSize, writeNUnsafe)

107−import Streamly.Internal.Data.Fold.Types (Fold(..))

107+import Streamly.Internal.Data.Fold.Type (Fold(..))

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

109import Streamly.Internal.Data.Stream.Serial (SerialT)

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

111import Streamly.Internal.Data.Tuple.Strict (Tuple'(..))

112−import Streamly.Internal.Data.Unfold.Types (Unfold(..))

112+import Streamly.Internal.Data.Unfold.Type (Unfold(..))

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

114import Streamly.Prelude (MonadAsync)

115

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

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

120import qualified Streamly.Internal.Data.Array.Foreign as A

121import qualified Streamly.Internal.Data.Array.Stream.Foreign as AS

122−import qualified Streamly.Internal.Data.Fold.Types as FL

122+import qualified Streamly.Internal.Data.Fold.Type as FL

123import qualified Streamly.Prelude as S

124import qualified Streamly.Network.Socket as SK

125import qualified Streamly.Internal.Network.Socket as ISK

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

@@ -88,22 +88,22 @@ import Prelude hiding (read)

88import qualified Network.Socket as Net

89

90import Streamly.Prelude (MonadAsync)

91−import Streamly.Internal.Data.Unfold.Types (Unfold(..))

91+import Streamly.Internal.Data.Unfold.Type (Unfold(..))

92import Streamly.Internal.Data.Array.Stream.Foreign (lpackArraysChunksOf)

93−import Streamly.Internal.Data.Array.Foreign.Types (Array(..))

93+import Streamly.Internal.Data.Array.Foreign.Type (Array(..))

94−import Streamly.Internal.Data.Array.Foreign.Mut.Types (mutableArray)

94+import Streamly.Internal.Data.Array.Foreign.Mut.Type (mutableArray)

95import Streamly.Internal.Data.Stream.Serial (SerialT)

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

97import Streamly.Data.Fold (Fold)

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

99

100import qualified Streamly.Data.Fold as FL

101−import qualified Streamly.Internal.Data.Fold.Types as FL

101+import qualified Streamly.Internal.Data.Fold.Type as FL

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

103import qualified Streamly.Internal.Data.Array.Foreign as IA

104import qualified Streamly.Data.Array.Foreign as A

105import qualified Streamly.Internal.Data.Array.Stream.Foreign as AS

106−import qualified Streamly.Internal.Data.Array.Foreign.Types as A

106+import qualified Streamly.Internal.Data.Array.Foreign.Type as A

107import qualified Streamly.Prelude as S

108import qualified Streamly.Internal.Data.Stream.StreamD.Type as D

109

@@ -381,9 +381,9 @@ readChunksWithBufferOf = Unfold step return

381

382-- | Unfolds a socket into a stream of 'Word8' arrays. Requests to the socket

383-- are performed using a buffer of size

384−-- 'Streamly.Internal.Data.Array.Foreign.Types.defaultChunkSize'. The

384+-- 'Streamly.Internal.Data.Array.Foreign.Type.defaultChunkSize'. The

385-- size of arrays in the resulting stream are therefore less than or equal to

386−-- 'Streamly.Internal.Data.Array.Foreign.Types.defaultChunkSize'.

386+-- 'Streamly.Internal.Data.Array.Foreign.Type.defaultChunkSize'.

387--

388-- @since 0.7.0

389{-# INLINE readChunks #-}

@@ -430,7 +430,7 @@ readWithBufferOf = UF.concat readChunksWithBufferOf A.read

430

431-- | Unfolds a 'Socket' into a byte stream. IO requests to the socket are

432-- performed in sizes of

433−-- 'Streamly.Internal.Data.Array.Foreign.Types.defaultChunkSize'.

433+-- 'Streamly.Internal.Data.Array.Foreign.Type.defaultChunkSize'.

434--

435-- @since 0.7.0

436{-# INLINE read #-}

src/Streamly/Internal/Ring/Foreign.hs+1−1

@@ -41,7 +41,7 @@ import Prelude hiding (length, concat)

41

42import Control.Monad.IO.Class (MonadIO(..))

43

44−import qualified Streamly.Internal.Data.Array.Foreign.Types as A

44+import qualified Streamly.Internal.Data.Array.Foreign.Type as A

45

46-- | A ring buffer is a mutable array of fixed size. Initially the array is

47-- empty, with ringStart pointing at the start of allocated memory. We call the

src/Streamly/Internal/Unicode/Stream.hs+1−1

@@ -88,7 +88,7 @@ import Streamly.Internal.Data.Stream.IsStream (IsStream)

88import Streamly.Internal.Data.Stream.StreamD (Stream(..), Step (..))

89import Streamly.Internal.Data.Tuple.Strict (Tuple'(..))

90

91−import qualified Streamly.Internal.Data.Array.Foreign.Types as A

91+import qualified Streamly.Internal.Data.Array.Foreign.Type as A

92import qualified Streamly.Internal.Data.Stream.IsStream as S

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

94

src/Streamly/Network/Socket.hs+2−2

@@ -64,9 +64,9 @@

64-- = Programmer Notes

65--

66-- Read IO requests to connected stream sockets are performed in chunks of

67−-- 'Streamly.Internal.Data.Array.Foreign.Types.defaultChunkSize'. Unless specified

67+-- 'Streamly.Internal.Data.Array.Foreign.Type.defaultChunkSize'. Unless specified

68-- otherwise in the API, writes are collected into chunks of

69−-- 'Streamly.Internal.Data.Array.Foreign.Types.defaultChunkSize' before they are

69+-- 'Streamly.Internal.Data.Array.Foreign.Type.defaultChunkSize' before they are

70-- written to the socket. APIs are provided to control the chunking behavior.

71--

72-- > import qualified Streamly.Network.Socket as SK

streamly.cabal+13−13

@@ -439,31 +439,31 @@ library

439 -- streamly-core-stream

440 , Streamly.Internal.Data.SVar

441 , Streamly.Internal.Data.Stream.StreamK.Type

442− , Streamly.Internal.Data.Fold.Types

442+ , Streamly.Internal.Data.Fold.Type

443 , Streamly.Internal.Data.Stream.StreamD.Step

444 , Streamly.Internal.Data.Stream.StreamD.Type

445 , Streamly.Internal.Data.Stream.StreamDK.Type

446− , Streamly.Internal.Data.Unfold.Types

446+ , Streamly.Internal.Data.Unfold.Type

447 , Streamly.Internal.Data.Producer.Type

448 , Streamly.Internal.Data.Producer

449 , Streamly.Internal.Data.Producer.Source

450− , Streamly.Internal.Data.Sink.Types

450+ , Streamly.Internal.Data.Sink.Type

451− , Streamly.Internal.Data.Parser.ParserK.Types

451+ , Streamly.Internal.Data.Parser.ParserK.Type

452− , Streamly.Internal.Data.Parser.ParserD.Types

452+ , Streamly.Internal.Data.Parser.ParserD.Type

453− , Streamly.Internal.Data.Pipe.Types

453+ , Streamly.Internal.Data.Pipe.Type

454

455 -- Unboxed IORef

456 , Streamly.Internal.Data.IORef.Prim

457

458 -- streamly-core-array

459 -- May depend on streamly-core-stream

460− , Streamly.Internal.Data.Array.Foreign.Mut.Types

460+ , Streamly.Internal.Data.Array.Foreign.Mut.Type

461− , Streamly.Internal.Data.Array.Foreign.Types

461+ , Streamly.Internal.Data.Array.Foreign.Type

462− , Streamly.Internal.Data.Array.Prim.Mut.Types

462+ , Streamly.Internal.Data.Array.Prim.Mut.Type

463− , Streamly.Internal.Data.Array.Prim.Types

463+ , Streamly.Internal.Data.Array.Prim.Type

464− , Streamly.Internal.Data.Array.Prim.Pinned.Mut.Types

464+ , Streamly.Internal.Data.Array.Prim.Pinned.Mut.Type

465− , Streamly.Internal.Data.Array.Prim.Pinned.Types

465+ , Streamly.Internal.Data.Array.Prim.Pinned.Type

466− , Streamly.Internal.Data.SmallArray.Types

466+ , Streamly.Internal.Data.SmallArray.Type

467

468 -- streamly-base-streams

469 , Streamly.Internal.Data.Stream.StreamK

test/Streamly/Test/Common/Array.hs+3−3

@@ -29,18 +29,18 @@ type Array = A.SmallArray

29import Data.Word(Word8)

30

31import qualified Streamly.Internal.Data.Array.Foreign as A

32−import qualified Streamly.Internal.Data.Array.Foreign.Types as A

32+import qualified Streamly.Internal.Data.Array.Foreign.Type as A

33import qualified Streamly.Internal.Data.Stream.IsStream as IP

34import qualified Streamly.Internal.Data.Array.Stream.Foreign as AS

35type Array = A.Array

36#elif defined(DATA_ARRAY_PRIM_PINNED)

37import qualified Streamly.Internal.Data.Array.Prim.Pinned as A

38−import qualified Streamly.Internal.Data.Array.Prim.Pinned.Types as A

38+import qualified Streamly.Internal.Data.Array.Prim.Pinned.Type as A

39import qualified Streamly.Internal.Data.Stream.IsStream as IP

40type Array = A.Array

41#elif defined(DATA_ARRAY_PRIM)

42import qualified Streamly.Internal.Data.Array.Prim as A

43−import qualified Streamly.Internal.Data.Array.Prim.Types as A

43+import qualified Streamly.Internal.Data.Array.Prim.Type as A

44import qualified Streamly.Internal.Data.Stream.IsStream as IP

45type Array = A.Array

46#else

test/Streamly/Test/Network/Inet/TCP.hs+1−1

@@ -19,7 +19,7 @@ import Streamly.Prelude (SerialT)

19import Test.QuickCheck (Property)

20import Test.QuickCheck.Monadic (monadicIO, assert, run)

21

22−import qualified Streamly.Internal.Data.Array.Foreign.Types as Array

22+import qualified Streamly.Internal.Data.Array.Foreign.Type as Array

23import qualified Streamly.Internal.Data.Unfold as Unfold

24import qualified Streamly.Internal.Network.Inet.TCP as TCP

25import qualified Streamly.Internal.Network.Socket as Socket

test/Streamly/Test/Network/Socket.hs+1−1

@@ -19,7 +19,7 @@ import Streamly.Prelude (SerialT)

19import Test.QuickCheck (Property)

20import Test.QuickCheck.Monadic (monadicIO, assert, run)

21

22−import qualified Streamly.Internal.Data.Array.Foreign.Types as Array

22+import qualified Streamly.Internal.Data.Array.Foreign.Type as Array

23import qualified Streamly.Internal.Network.Inet.TCP as TCP

24import qualified Streamly.Internal.Network.Socket as Socket

25import qualified Streamly.Internal.Unicode.Stream as Unicode