297574d · streamly · git.iko.soy

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

compare with master

unifiedsplit

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

37import Prelude hiding ()

38

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

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

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

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

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

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

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

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

20-- 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

22-- arrays at once.

23--

24-- 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 @@

18-- element stream. For example:

19--

20-- >>> 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

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

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

24-- >>> 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 @@

1-- |

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

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

4-- License : BSD3-3-Clause

5-- Maintainer : streamly@composewell.com

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

8--

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

10--

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

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

12 (

13 -- * Creation

14 arraysOf

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

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

117 (Step(..), snoc, reduce)

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

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

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

122

123-------------------------------------------------------------------------------

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

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

125import Streamly.Internal.Data.Array.Type

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

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

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

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

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

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

131

132import qualified Streamly.Data.Fold as FL

133import qualified Streamly.Data.Array as A

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

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

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

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

core/streamly-core.cabal+1−1

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

313 , Streamly.Internal.Data.Stream.Reduce

314 , Streamly.Internal.Data.Stream.Top

315 , Streamly.Internal.Data.Stream

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

316 , Streamly.Internal.Data.Stream.Zip

317 , Streamly.Internal.Data.Stream.Zip

317 , Streamly.Internal.Data.Stream.TypeGen

318 , Streamly.Internal.Data.Stream.TypeGen

318 , Streamly.Internal.Data.List

319 , Streamly.Internal.Data.List

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

322 , Streamly.Internal.Data.Array

323 , Streamly.Internal.Data.Array

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

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

324 , Streamly.Internal.Data.Array.Fold

325 , Streamly.Internal.Data.Array.Fold

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

326

327 -- streamly-serde

328 , Streamly.Internal.Data.Binary.Decode

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

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

147import qualified Streamly.Data.Fold as FL

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

149 (Array(..), newPinnedBytes, asPtrUnsafe)

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

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

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

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

153 (Stream(..), Step(..))

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

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

121import qualified Streamly.Data.Fold as FL

122import qualified Streamly.Data.Unfold as UF

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

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

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

127import 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)

87import qualified Network.Socket as Net

88

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

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

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

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

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

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

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

100 (unsafeFreeze, asPtrUnsafe, byteLength, writeNUnsafe)

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

102 (Array(..), newPinnedBytes, asPtrUnsafe)

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

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

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

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

106 (Stream(..), Step(..))

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

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

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

11

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

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

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

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

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

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

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

20

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

23import qualified Streamly.Prelude as S

24import qualified Streamly.Unicode.Stream as SS

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