4070c13 · streamly · git.iko.soy

git.iko.soy/streamly

Rename Streamly.Internal.Memory.Array.Types

According to the new module structure, it should be Streamly.Internal.Data.Array.Storable.Foreign.Types

commit4070c139377bcfe7ba2c7d194de777d1b5a2aacd authoradithyaov <adi.obilisetty@gmail.com> dateFri 28 Aug 2020, 02:28 (6 years ago) parentc2be163

23 files changed+49−49

compare with master

unifiedsplit

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

@@ -44,7 +44,7 @@ import qualified Streamly.Internal.Data.Stream.StreamD as D

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

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

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

47−import qualified Streamly.Internal.Memory.Array.Types as AT

47+import qualified Streamly.Internal.Data.Array.Storable.Foreign.Types as AT

4848import qualified Streamly.Internal.Memory.ArrayStream as AS

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

5050import qualified Streamly.Prelude as S

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

@@ -49,7 +49,7 @@ import Streamly.Internal.Data.Stream.StreamD.Type (Step(..))

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

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

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

52−import qualified Streamly.Internal.Memory.Array.Types as AT

52+import qualified Streamly.Internal.Data.Array.Storable.Foreign.Types as AT

5353

5454import Test.Inspection

5555#endif

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

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

130130import qualified GHC.IO.FD as FD

131131import qualified GHC.IO.Device as RawIO

132132

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

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

134134import Streamly.Internal.Data.Array.Storable.Foreign.Mut.Types (mutableArray)

135135

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

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

138138

139139#if !defined(mingw32_HOST_OS)

140−import Streamly.Internal.Memory.Array.Types (groupIOVecsOf)

140+import Streamly.Internal.Data.Array.Storable.Foreign.Types (groupIOVecsOf)

141141import Streamly.Internal.Data.Stream.StreamD (toStreamD)

142142import Streamly.Internal.Data.Stream.StreamD.Type (fromStreamD)

143143import qualified Streamly.FileSystem.FDIO as RawIO hiding (write)

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

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

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

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

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

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

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

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

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

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

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

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

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

5353 -- are written to the IO device.

5454

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

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

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

551551 step' gst (SpliceInitial st) = do

552552 when (n <= 0) $

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

554− error $ "Streamly.Internal.Memory.Array.Types.packArraysChunksOf: the size of "

554+ error $ "Streamly.Internal.Data.Array.Storable.Foreign.Types.packArraysChunksOf: the size of "

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

556556 r <- step gst st

557557 case r of

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

601601 initial = do

602602 when (n <= 0) $

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

604− error $ "Streamly.Internal.Memory.Array.Types.packArraysChunksOf: the size of "

604+ error $ "Streamly.Internal.Data.Array.Storable.Foreign.Types.packArraysChunksOf: the size of "

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

606606 r1 <- initial1

607607 return (Tuple3' Nothing' 0 r1)

src/Streamly/Internal/Memory/Array/Types.hs → src/Streamly/Internal/Data/Array/Storable/Foreign/Types.hsrenamed+2−2

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

11#include "inline.hs"

33-- |

4−-- Module : Streamly.Internal.Memory.Array.Types

4+-- Module : Streamly.Internal.Data.Array.Storable.Foreign.Types

66--

77-- License : BSD3-3-Clause

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

99-- Stability : experimental

1010-- Portability : GHC

1111--

12−module Streamly.Internal.Memory.Array.Types

12+module Streamly.Internal.Data.Array.Storable.Foreign.Types

1313 (

1414 Array (..)

1515

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

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

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

247247import Streamly.Internal.Data.Pipe.Types

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

249−-- import Streamly.Internal.Memory.Array.Types (Array)

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

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

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

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

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

256256

257257-- import Streamly.Internal.Data.Strict

258258

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

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

260260-- import qualified Streamly.Prelude as S

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

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

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

@@ -554,7 +554,7 @@ import Streamly.Internal.Data.Stream.Enumeration

554554import Streamly.Internal.Data.Fold.Types (Fold (..), Fold2 (..))

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

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

557−import Streamly.Internal.Memory.Array.Types (Array, writeNUnsafe)

557+import Streamly.Internal.Data.Array.Storable.Foreign.Types (Array, writeNUnsafe)

558558import Streamly.Internal.Data.SVar (MonadAsync, defState, Rate)

559559import Streamly.Internal.Data.Stream.Combinators (inspectMode, maxYields)

560560import Streamly.Internal.Data.Stream.Prelude

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

@@ -329,7 +329,7 @@ import Streamly.Internal.Data.IORef.Prim (Prim)

329329import Streamly.Internal.Data.Time.Units

330330 (TimeUnit64, toRelTime64, diffAbsTime64, RelTime64)

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

332−import Streamly.Internal.Memory.Array.Types (Array(..))

332+import Streamly.Internal.Data.Array.Storable.Foreign.Types (Array(..))

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

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

335335import Streamly.Internal.Data.Pipe.Types (Pipe(..), PipeState(..))

@@ -342,7 +342,7 @@ import Streamly.Internal.Data.Stream.SVar (fromConsumer, pushToFold)

342342

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

344344import qualified Streamly.Internal.Data.Pipe.Types as Pipe

345−import qualified Streamly.Internal.Memory.Array.Types as A

345+import qualified Streamly.Internal.Data.Array.Storable.Foreign.Types as A

346346import qualified Streamly.Internal.Data.Array.Storable.Foreign.Mut.Types as MA

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

348348import qualified Streamly.Memory.Ring as RB

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

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

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

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

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

67−-- import Streamly.Internal.Memory.Array.Types

67+-- import Streamly.Internal.Data.Array.Storable.Foreign.Types

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

6969-- lpackArraysChunksOf)

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

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

166166

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

168168-- device are performed using a buffer of size

169−-- 'Streamly.Internal.Memory.Array.Types.defaultChunkSize'. The

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

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

171−-- 'Streamly.Internal.Memory.Array.Types.defaultChunkSize'.

171+-- 'Streamly.Internal.Data.Array.Storable.Foreign.Types.defaultChunkSize'.

172172--

173173-- @since 0.7.0

174174{-# INLINE readChunks #-}

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

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

344344--

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

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

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

347347--

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

349349-- need some extra perf boost.

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

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

394394--

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

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

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

397397-- to the IO device.

398398--

399399-- @since 0.7.0

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

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

165165import Streamly (SerialT)

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

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

168−import Streamly.Internal.Memory.Array.Types (Array(..))

168+import Streamly.Internal.Data.Array.Storable.Foreign.Types (Array(..))

169169import System.IO (Handle, hClose)

170170

171171import qualified Data.List.NonEmpty as NonEmpty

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

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

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

162162import Streamly (SerialT)

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

164−import Streamly.Internal.Memory.Array.Types (Array(..))

164+import Streamly.Internal.Data.Array.Storable.Foreign.Types (Array(..))

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

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

167167import Control.Concurrent.MVar (readMVar)

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

@@ -96,7 +96,7 @@ import qualified System.IO as SIO

9696

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

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

99−import Streamly.Internal.Memory.Array.Types

99+import Streamly.Internal.Data.Array.Storable.Foreign.Types

100100 (Array(..), defaultChunkSize, writeNUnsafe)

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

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

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

243243

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

245245-- device are performed using a buffer of size

246−-- 'Streamly.Internal.Memory.Array.Types.defaultChunkSize'. The

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

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

248−-- 'Streamly.Internal.Memory.Array.Types.defaultChunkSize'.

248+-- 'Streamly.Internal.Data.Array.Storable.Foreign.Types.defaultChunkSize'.

249249--

250250-- /Internal/

251251{-# INLINE readChunks #-}

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

262262

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

264264-- performed in sizes of

265−-- 'Streamly.Internal.Memory.Array.Types.defaultChunkSize'.

265+-- 'Streamly.Internal.Data.Array.Storable.Foreign.Types.defaultChunkSize'.

266266--

267267-- @since 0.7.0

268268{-# INLINE read #-}

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

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

380380--

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

382−-- 'Streamly.Internal.Memory.Array.Types.defaultChunkSize' before writing to

382+-- 'Streamly.Internal.Data.Array.Storable.Foreign.Types.defaultChunkSize' before writing to

383383-- the IO device.

384384--

385385-- /Internal/

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

@@ -113,7 +113,7 @@ import Streamly (MonadAsync)

113113import Streamly.Data.Fold (Fold)

114114import Streamly.Internal.Data.Fold.Types (Fold2(..))

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

116−import Streamly.Internal.Memory.Array.Types

116+import Streamly.Internal.Data.Array.Storable.Foreign.Types

117117 (Array(..), writeNUnsafe, defaultChunkSize, lpackArraysChunksOf

118118 , unsafeFreezeWithShrink)

119119import Streamly.Internal.Data.Array.Storable.Foreign.Mut.Types (mutableArray)

@@ -255,9 +255,9 @@ getBytes = toBytes stdin

255255

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

257257-- device are performed using a buffer of size

258−-- 'Streamly.Internal.Memory.Array.Types.defaultChunkSize'. The

258+-- 'Streamly.Internal.Data.Array.Storable.Foreign.Types.defaultChunkSize'. The

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

260−-- 'Streamly.Internal.Memory.Array.Types.defaultChunkSize'.

260+-- 'Streamly.Internal.Data.Array.Storable.Foreign.Types.defaultChunkSize'.

261261--

262262-- @since 0.7.0

263263{-# INLINE readChunks #-}

@@ -294,7 +294,7 @@ toBytesWithBufferOf chunkSize h = AS.concat $ toChunksWithBufferOf chunkSize h

294294--

295295-- | Unfolds a file handle into a byte stream. IO requests to the device are

296296-- performed in sizes of

297−-- 'Streamly.Internal.Memory.Array.Types.defaultChunkSize'.

297+-- 'Streamly.Internal.Data.Array.Storable.Foreign.Types.defaultChunkSize'.

298298--

299299-- @since 0.7.0

300300{-# INLINE read #-}

@@ -411,7 +411,7 @@ fromBytesWithBufferOf n h m = fromChunks h $ S.arraysOf n m

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

412412--

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

414−-- up to 'Streamly.Internal.Memory.Array.Types.defaultChunkSize' before writing.

414+-- up to 'Streamly.Internal.Data.Array.Storable.Foreign.Types.defaultChunkSize' before writing.

415415--

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

417417-- need some extra perf boost.

@@ -469,7 +469,7 @@ writeWithBufferOf2 n = FL.lchunksOf2 n (writeNUnsafe n) writeChunks2

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

470470--

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

472−-- up to 'Streamly.Internal.Memory.Array.Types.defaultChunkSize' before writing

472+-- up to 'Streamly.Internal.Data.Array.Storable.Foreign.Types.defaultChunkSize' before writing

473473-- to the IO device.

474474--

475475-- @since 0.7.0

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

@@ -159,11 +159,11 @@ import GHC.IO (IO(..))

159159

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

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

162−import Streamly.Internal.Memory.Array.Types (Array(..), length)

162+import Streamly.Internal.Data.Array.Storable.Foreign.Types (Array(..), length)

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

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

165165

166−import qualified Streamly.Internal.Memory.Array.Types as A

166+import qualified Streamly.Internal.Data.Array.Storable.Foreign.Types as A

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

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

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

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

@@ -41,12 +41,12 @@ import Foreign.Ptr (minusPtr, plusPtr, castPtr)

4141import Foreign.Storable (Storable(..))

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

4343

44−import Streamly.Internal.Memory.Array.Types (Array(..), length)

44+import Streamly.Internal.Data.Array.Storable.Foreign.Types (Array(..), length)

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

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

4747

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

49−import qualified Streamly.Internal.Memory.Array.Types as A

49+import qualified Streamly.Internal.Data.Array.Storable.Foreign.Types as A

5050import qualified Streamly.Internal.Data.Array.Storable.Foreign.Mut.Types as MA

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

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

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

@@ -109,7 +109,7 @@ import Streamly.Internal.Data.SVar (fork)

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

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

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

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

112+import Streamly.Internal.Data.Array.Storable.Foreign.Types (Array(..), defaultChunkSize, writeNUnsafe)

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

114114

115115import qualified Control.Monad.Catch as MC

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

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

8989

9090import Streamly (MonadAsync)

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

92−import Streamly.Internal.Memory.Array.Types (Array(..), lpackArraysChunksOf)

92+import Streamly.Internal.Data.Array.Storable.Foreign.Types (Array(..), lpackArraysChunksOf)

9393import Streamly.Internal.Data.Array.Storable.Foreign.Mut.Types (mutableArray)

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

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

@@ -102,7 +102,7 @@ import qualified Streamly.Internal.Data.Unfold as UF

102102import qualified Streamly.Internal.Memory.Array as IA

103103import qualified Streamly.Memory.Array as A

104104import qualified Streamly.Internal.Memory.ArrayStream as AS

105−import qualified Streamly.Internal.Memory.Array.Types as A

105+import qualified Streamly.Internal.Data.Array.Storable.Foreign.Types as A

106106import qualified Streamly.Prelude as S

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

108108

@@ -380,9 +380,9 @@ readChunksWithBufferOf = Unfold step return

380380

381381-- | Unfolds a socket into a stream of 'Word8' arrays. Requests to the socket

382382-- are performed using a buffer of size

383−-- 'Streamly.Internal.Memory.Array.Types.defaultChunkSize'. The

383+-- 'Streamly.Internal.Data.Array.Storable.Foreign.Types.defaultChunkSize'. The

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

385−-- 'Streamly.Internal.Memory.Array.Types.defaultChunkSize'.

385+-- 'Streamly.Internal.Data.Array.Storable.Foreign.Types.defaultChunkSize'.

386386--

387387-- @since 0.7.0

388388{-# INLINE readChunks #-}

@@ -429,7 +429,7 @@ readWithBufferOf = UF.concat readChunksWithBufferOf A.read

429429

430430-- | Unfolds a 'Socket' into a byte stream. IO requests to the socket are

431431-- performed in sizes of

432−-- 'Streamly.Internal.Memory.Array.Types.defaultChunkSize'.

432+-- 'Streamly.Internal.Data.Array.Storable.Foreign.Types.defaultChunkSize'.

433433--

434434-- @since 0.7.0

435435{-# INLINE read #-}

src/Streamly/Internal/Unicode/Stream.hs+1−1

@@ -74,7 +74,7 @@ import Streamly.Internal.Data.SVar (adaptState)

7474import Streamly.Internal.Data.Stream.StreamD (Stream(..), Step (..))

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

7676

77−import qualified Streamly.Internal.Memory.Array.Types as A

77+import qualified Streamly.Internal.Data.Array.Storable.Foreign.Types as A

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

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

8080

src/Streamly/Memory/Ring.hs+1−1

@@ -37,7 +37,7 @@ import Prelude hiding (length, concat)

3737

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

3939

40−import qualified Streamly.Internal.Memory.Array.Types as A

40+import qualified Streamly.Internal.Data.Array.Storable.Foreign.Types as A

4141

4242-- | A ring buffer is a mutable array of fixed size. Initially the array is

4343-- empty, with ringStart pointing at the start of allocated memory. We call the

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

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

6464-- = Programmer Notes

6565--

6666-- Read IO requests to connected stream sockets are performed in chunks of

67−-- 'Streamly.Internal.Memory.Array.Types.defaultChunkSize'. Unless specified

67+-- 'Streamly.Internal.Data.Array.Storable.Foreign.Types.defaultChunkSize'. Unless specified

6868-- otherwise in the API, writes are collected into chunks of

69−-- 'Streamly.Internal.Memory.Array.Types.defaultChunkSize' before they are

69+-- 'Streamly.Internal.Data.Array.Storable.Foreign.Types.defaultChunkSize' before they are

7070-- written to the socket. APIs are provided to control the chunking behavior.

7171--

7272-- > import qualified Streamly.Network.Socket as SK

streamly.cabal+1−1

@@ -430,7 +430,7 @@ library

430430 , Streamly.Internal.Data.SmallArray.Types

431431 , Streamly.Internal.Data.SmallArray

432432 , Streamly.Internal.Data.Array.Storable.Foreign.Mut.Types

433− , Streamly.Internal.Memory.Array.Types

433+ , Streamly.Internal.Data.Array.Storable.Foreign.Types

434434 , Streamly.Internal.Memory.Array

435435 , Streamly.Internal.Memory.ArrayStream

436436

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

@@ -26,7 +26,7 @@ import qualified Streamly.Internal.Data.SmallArray as A

2626type Array = A.SmallArray

2727#elif defined(TEST_ARRAY)

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

29−import qualified Streamly.Internal.Memory.Array.Types as A

29+import qualified Streamly.Internal.Data.Array.Storable.Foreign.Types as A

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

3131type Array = A.Array

3232#elif defined(DATA_ARRAY_PRIM_PINNED)