297574d · streamly · git.iko.soy

git.iko.soy/streamly

Rename Array.Stream module to Stream.Chunked

commit297574d7f118f67e7e7b101b02874f6947c8707a authorRanjeet Kumar Ranjan <ranjeetr@composewell.com> dateMon 14 Nov 2022, 18:40 (4 years ago) parentdfe3e45

12 files changed+15−15

compare with master

unifiedsplit

benchmark/Streamly/Benchmark/Data/Array/Stream.hs+1−1

@@ -37,7 +37,7 @@ import System.Random (randomRIO)

3737import Prelude hiding ()

3838

3939import qualified Streamly.Internal.Data.Array as Array

40−import qualified Streamly.Internal.Data.Array.Stream as ArrayStream

40+import qualified Streamly.Internal.Data.Stream.Chunked as ArrayStream

4141import qualified Streamly.Internal.Data.Fold as Fold

4242import qualified Streamly.Internal.Data.Parser as Parser

4343import qualified Streamly.Internal.Data.Stream as S

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

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

1818-- less efficient compared to folding via streams. 'Semigroup' and 'Monoid'

1919-- instances should be used with care; concatenating arrays using binary

2020-- operations can be highly inefficient. Instead, use

21−-- 'Streamly.Internal.Data.Array.Stream.toArray' to concatenate N

21+-- 'Streamly.Internal.Data.Stream.Chunked.toArray' to concatenate N

2222-- arrays at once.

2323--

2424-- Each array is one pointer visible to the GC. Too many small arrays (e.g.

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

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

1818-- element stream. For example:

1919--

2020-- >>> import qualified Streamly.Data.Fold as Fold

21−-- >>> import qualified Streamly.Internal.Data.Array.Stream as ArrayStream

21+-- >>> import qualified Streamly.Internal.Data.Stream.Chunked as ArrayStream

2222-- >>> import qualified Streamly.Internal.Data.Array.Fold as ArrayFold

2323-- >>> import qualified Streamly.Internal.Data.Stream as Stream (arraysOf)

2424-- >>> import qualified Streamly.Data.Stream as Stream

core/src/Streamly/Internal/Data/Array/Stream.hs → core/src/Streamly/Internal/Data/Stream/Chunked.hsrenamed+2−2

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

11-- |

2−-- Module : Streamly.Internal.Data.Array.Stream

2+-- Module : Streamly.Internal.Data.Stream.Chunked

44-- License : BSD3-3-Clause

55-- Maintainer : streamly@composewell.com

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

88--

99-- Combinators to efficiently manipulate streams of immutable arrays.

1010--

11−module Streamly.Internal.Data.Array.Stream

11+module Streamly.Internal.Data.Stream.Chunked

1212 (

1313 -- * Creation

1414 arraysOf

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

@@ -117,7 +117,7 @@ import qualified Streamly.Internal.Data.Fold.Type as FL

117117 (Step(..), snoc, reduce)

118118import qualified Streamly.Internal.Data.Unfold as UF (bracketIO)

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

120−import qualified Streamly.Internal.Data.Array.Stream as AS

120+import qualified Streamly.Internal.Data.Stream.Chunked as AS

121121import qualified Streamly.Data.Stream as S (fold, bracketIO, mapM)

122122

123123-------------------------------------------------------------------------------

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

@@ -125,14 +125,14 @@ import Streamly.Internal.Data.Unfold.Type (Unfold(..))

125125import Streamly.Internal.Data.Array.Type

126126 (Array(..), writeNUnsafe, unsafeFreezeWithShrink, byteLength)

127127import Streamly.Internal.Data.Stream.Type (Stream)

128−import Streamly.Internal.Data.Array.Stream (lpackArraysChunksOf)

128+import Streamly.Internal.Data.Stream.Chunked (lpackArraysChunksOf)

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

130130import Streamly.Internal.System.IO (defaultChunkSize)

131131

132132import qualified Streamly.Data.Fold as FL

133133import qualified Streamly.Data.Array as A

134134import qualified Streamly.Internal.Data.Array.Type as A

135−import qualified Streamly.Internal.Data.Array.Stream as AS

135+import qualified Streamly.Internal.Data.Stream.Chunked as AS

136136import qualified Streamly.Internal.Data.Array.Mut.Type as MArray

137137import qualified Streamly.Internal.Data.Refold.Type as Refold

138138import qualified Streamly.Internal.Data.Fold.Type as FL(refoldMany)

core/streamly-core.cabal+1−1

@@ -313,6 +313,7 @@ library

313313 , Streamly.Internal.Data.Stream.Reduce

314314 , Streamly.Internal.Data.Stream.Top

315315 , Streamly.Internal.Data.Stream

316+ , Streamly.Internal.Data.Stream.Chunked

316317 , Streamly.Internal.Data.Stream.Zip

317318 , Streamly.Internal.Data.Stream.TypeGen

318319 , Streamly.Internal.Data.List

@@ -322,7 +323,6 @@ library

322323 , Streamly.Internal.Data.Array

323324 , Streamly.Internal.Data.Array.Mut.Stream

324325 , Streamly.Internal.Data.Array.Fold

325− , Streamly.Internal.Data.Array.Stream

326326

327327 -- streamly-serde

328328 , Streamly.Internal.Data.Binary.Decode

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

@@ -147,7 +147,7 @@ import qualified Streamly.Data.Array as A

147147import qualified Streamly.Data.Fold as FL

148148import qualified Streamly.Internal.Data.Array.Mut as MArray

149149 (Array(..), newPinnedBytes, asPtrUnsafe)

150−import qualified Streamly.Internal.Data.Array.Stream as AS

150+import qualified Streamly.Internal.Data.Stream.Chunked as AS

151151import qualified Streamly.Internal.Data.Stream as S

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

153153 (Stream(..), Step(..))

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

@@ -121,7 +121,7 @@ import qualified Streamly.Data.Array as A

121121import qualified Streamly.Data.Fold as FL

122122import qualified Streamly.Data.Unfold as UF

123123import qualified Streamly.Internal.Data.Unfold as UF (bracketIO, first)

124−import qualified Streamly.Internal.Data.Array.Stream as AS

124+import qualified Streamly.Internal.Data.Stream.Chunked as AS

125125import qualified Streamly.Internal.Data.Fold.Type as FL (Step(..))

126126import qualified Streamly.Internal.Data.Stream as S

127127import qualified Streamly.Internal.Data.Stream.Exception.Lifted as S

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

@@ -87,7 +87,7 @@ import Prelude hiding (read)

8787import qualified Network.Socket as Net

8888

8989import Streamly.Internal.Data.Array.Type (Array(..))

90−import Streamly.Internal.Data.Array.Stream (lpackArraysChunksOf)

90+import Streamly.Internal.Data.Stream.Chunked (lpackArraysChunksOf)

9191import Streamly.Internal.Data.Fold (Fold)

9292import Streamly.Internal.Data.Stream.Type (Stream)

9393import Streamly.Internal.Data.Unfold.Type (Unfold(..))

@@ -100,7 +100,7 @@ import qualified Streamly.Internal.Data.Array.Type as A

100100 (unsafeFreeze, asPtrUnsafe, byteLength, writeNUnsafe)

101101import qualified Streamly.Internal.Data.Array.Mut as MArray

102102 (Array(..), newPinnedBytes, asPtrUnsafe)

103−import qualified Streamly.Internal.Data.Array.Stream as AS

103+import qualified Streamly.Internal.Data.Stream.Chunked as AS

104104import qualified Streamly.Internal.Data.Stream as S

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

106106 (Stream(..), Step(..))

test/Streamly/Test/Data/Array/Stream.hs+1−1

@@ -10,7 +10,7 @@ import Test.QuickCheck (forAll, Property, vectorOf, Gen, Arbitrary (arbitrary))

1010import Test.QuickCheck.Monadic (monadicIO, run)

1111

1212import qualified Streamly.Internal.Data.Array as Array

13−import qualified Streamly.Internal.Data.Array.Stream as ArrayStream

13+import qualified Streamly.Internal.Data.Stream.Chunked as ArrayStream

1414import qualified Streamly.Internal.Data.Fold as Fold

1515import qualified Streamly.Internal.Data.Parser as Parser

1616import qualified Streamly.Internal.Data.Stream.IsStream as Stream

test/Streamly/Test/Unicode/Stream.hs+1−1

@@ -19,7 +19,7 @@ import Test.QuickCheck

1919import Test.QuickCheck.Monadic (run, monadicIO, assert)

2020

2121import qualified Streamly.Data.Array as A

22−import qualified Streamly.Internal.Data.Array.Stream as AS

22+import qualified Streamly.Internal.Data.Stream.Chunked as AS

2323import qualified Streamly.Prelude as S

2424import qualified Streamly.Unicode.Stream as SS

2525import qualified Streamly.Internal.Unicode.Stream as IUS