08e733d · streamly · git.iko.soy

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

compare with master

unifiedsplit

@@ -90,6 +90,7 @@ import Prelude hiding (null, last, (!!), read, concat, unlines)

90

91import Streamly.Data.Fold (Fold)

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

93+import Streamly.Internal.Data.MutByteArray.Type (MutByteArray)

93import Streamly.Internal.Data.Fold.Chunked (ChunkFold(..))

94import Streamly.Internal.Data.Fold.Chunked (ChunkFold(..))

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

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

95import Streamly.Internal.Data.Stream (Stream)

96import Streamly.Internal.Data.Stream (Stream)

@@ -174,7 +175,7 @@ interposeSuffix x = D.interposeSuffix x A.reader

174

175

175data FlattenState s =

176data FlattenState s =

176 OuterLoop s

177 OuterLoop s

177− | InnerLoop s !MA.MutableByteArray !Int !Int

178+ | InnerLoop s !MutByteArray !Int !Int

178

179

179-- XXX This is a special case of interposeSuffix, can be removed.

180-- XXX This is a special case of interposeSuffix, can be removed.

180-- XXX Remove monadIO constraint

181-- XXX Remove monadIO constraint

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

@@ -121,7 +121,8 @@ import GHC.Exts (IsList, IsString(..), Addr#)

121

122import GHC.IO (unsafePerformIO)

123import GHC.Ptr (Ptr(..))

124−import Streamly.Internal.Data.MutArray.Type (MutArray(..), MutByteArray)

124+import Streamly.Internal.Data.MutArray.Type (MutArray(..))

125+import Streamly.Internal.Data.MutByteArray.Type (MutByteArray)

125import Streamly.Internal.Data.Fold.Type (Fold(..))

126import Streamly.Internal.Data.Fold.Type (Fold(..))

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

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

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

128import Streamly.Internal.Data.StreamK.Type (StreamK)

core/src/Streamly/Internal/Data/MutArray/Type.hs−3

@@ -31,8 +31,6 @@ module Streamly.Internal.Data.MutArray.Type

31 -- ** Type

32 -- $arrayNotes

33 MutArray (..)

34− , MutByteArray

35− , MutableByteArray

36 , pin

34 , pin

37 , unpin

35 , unpin

38 , isPinned

36 , isPinned

@@ -257,7 +255,6 @@ import Foreign.C.Types (CSize(..), CInt(..))

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

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

258import Streamly.Internal.Data.MutByteArray.Type

256import Streamly.Internal.Data.MutByteArray.Type

259 ( MutByteArray(..)

257 ( MutByteArray(..)

260− , MutableByteArray

261 , PinnedState(..)

258 , PinnedState(..)

262 , getMutableByteArray#

259 , getMutableByteArray#

263 , putSliceUnsafe

260 , putSliceUnsafe

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

@@ -111,7 +111,7 @@ import GHC.IO.Encoding.Failure (isSurrogate)

111import GHC.Ptr (Ptr (..), plusPtr)

112import System.IO.Unsafe (unsafePerformIO)

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

114−import Streamly.Internal.Data.MutArray.Type (MutByteArray)

114+import Streamly.Internal.Data.MutByteArray.Type (MutByteArray)

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

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

117import Streamly.Internal.Data.Stream (Stream)