composewell/streamly
1
1
Fork 0
mirror of https://github.com/composewell/streamly.git synced 2024-08-16 23:10:36 +03:00
Code Issues Packages Projects Releases Wiki Activity

Move Stream.Chunked to Array.Stream

Browse Source
This commit is contained in:
Harendra Kumar 2023-11-24 05:03:44 +05:30
parent 41baea74b8
commit dfa2079542
7 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
benchmark/Streamly/Benchmark/Data/Array/Stream.hs
View File

@ -39,7 +39,7 @@ import Prelude hiding ()
import qualified Streamly.Data.Stream as Stream
import qualified Streamly.Internal.Data.Array as Array
import qualified Streamly.Internal.Data.Stream.Chunked as ArrayStream
import qualified Streamly.Internal.Data.Array.Stream as ArrayStream
import qualified Streamly.Internal.Data.Fold as Fold
import qualified Streamly.Internal.Data.Parser as Parser
import qualified Streamly.Internal.Data.Stream as Stream

4
core/src/Streamly/Internal/Data/Stream/Chunked.hs → core/src/Streamly/Internal/Data/Array/Stream.hs
View File

@ -1,6 +1,6 @@
{-# OPTIONS_GHC -Wno-deprecations #-}
-- |
-- Module : Streamly.Internal.Data.Stream.Chunked
-- Module : Streamly.Internal.Data.Array.Stream
-- Copyright : (c) 2019 Composewell Technologies
-- License : BSD3-3-Clause
-- Maintainer : streamly@composewell.com
@ -8,7 +8,7 @@
--
-- Combinators to efficiently manipulate streams of immutable arrays.
--
module Streamly.Internal.Data.Stream.Chunked
module Streamly.Internal.Data.Array.Stream
(
-- * Creation
chunksOf

4
core/src/Streamly/Internal/FileSystem/Handle.hs
View File

@ -133,14 +133,14 @@ import Streamly.Internal.Data.Unfold.Type (Unfold(..))
import Streamly.Internal.Data.Array.Type
(Array(..), pinnedWriteNUnsafe, unsafeFreezeWithShrink, byteLength)
import Streamly.Internal.Data.Stream.Type (Stream)
import Streamly.Internal.Data.Stream.Chunked (lpackArraysChunksOf)
import Streamly.Internal.Data.Array.Stream (lpackArraysChunksOf)
-- import Streamly.String (encodeUtf8, decodeUtf8, foldLines)
import Streamly.Internal.System.IO (defaultChunkSize)
import qualified Streamly.Data.Fold as FL
import qualified Streamly.Data.Array as A
import qualified Streamly.Internal.Data.Array.Type as A
import qualified Streamly.Internal.Data.Stream.Chunked as AS
import qualified Streamly.Internal.Data.Array.Stream as AS
import qualified Streamly.Internal.Data.MutArray.Type as MArray
import qualified Streamly.Internal.Data.Refold.Type as Refold
import qualified Streamly.Internal.Data.Fold.Type as FL(refoldMany)

2
core/streamly-core.cabal
View File

@ -316,12 +316,12 @@ library
-- streamly-containers (non-base)
, Streamly.Internal.Data.Fold
, Streamly.Internal.Data.Stream.Chunked
-- streamly-core-data-arrays
, Streamly.Internal.Data.Array.Generic
, Streamly.Internal.Data.Array
, Streamly.Internal.Data.MutArray.Stream
, Streamly.Internal.Data.Array.Stream
-- streamly-unicode-core
, Streamly.Internal.Unicode.Stream

2
src/Streamly/Internal/Network/Socket.hs
View File

@ -87,7 +87,7 @@ import Prelude hiding (read)
import qualified Network.Socket as Net
import Streamly.Internal.Data.Array (Array(..))
import Streamly.Internal.Data.Stream.Chunked (lpackArraysChunksOf)
import Streamly.Internal.Data.Array.Stream (lpackArraysChunksOf)
import Streamly.Data.Fold (Fold)
import Streamly.Data.Stream (Stream)
import Streamly.Internal.Data.Unfold (Unfold(..))

2
test/Streamly/Test/Data/Array/Stream.hs
View File

@ -10,7 +10,7 @@ import Test.QuickCheck (forAll, Property, vectorOf, Gen, Arbitrary (arbitrary))
import Test.QuickCheck.Monadic (assert, monadicIO, run)
import qualified Streamly.Internal.Data.Array as Array
import qualified Streamly.Internal.Data.Stream.Chunked as ArrayStream
import qualified Streamly.Internal.Data.Array.Stream as ArrayStream
import qualified Streamly.Internal.Data.Fold as Fold
import qualified Streamly.Internal.Data.Parser as Parser
import qualified Streamly.Internal.Data.Stream as Stream

2
test/Streamly/Test/Unicode/Stream.hs
View File

@ -20,7 +20,7 @@ import Test.QuickCheck.Monadic (run, monadicIO, assert)
import qualified Streamly.Data.Array as A
import qualified Streamly.Data.Stream as Stream
import qualified Streamly.Internal.Data.Stream.Chunked as AS
import qualified Streamly.Internal.Data.Array.Stream as AS
import qualified Streamly.Internal.Data.Stream as Stream
import qualified Streamly.Unicode.Stream as SS
import qualified Streamly.Internal.Unicode.Stream as IUS