ilyakooo0/streamly
1
0
Fork 0
mirror of https://github.com/ilyakooo0/streamly.git synced 2024-09-11 08:25:40 +03:00
Code Issues Packages Projects Releases Wiki Activity

Import Data.Stream instead of Data.Stream.StreamD

Browse Source
This commit is contained in:
Ranjeet Kumar Ranjan 2023-07-14 11:43:49 +05:30 committed by Harendra Kumar
parent c3072860ec
commit 69aa279c6c
82 changed files with 157 additions and 157 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -7,7 +7,7 @@ import System.Random (randomRIO)
import qualified Streamly.Data.Fold as Fold
import qualified Streamly.Data.Stream as S
import qualified Streamly.Internal.Data.Stream.StreamD as Stream
import qualified Streamly.Internal.Data.Stream as Stream
import Gauge
import Streamly.Benchmark.Common hiding (benchPureSrc)

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

@ -47,7 +47,7 @@ import Streamly.Internal.Data.Array.Mut (MutArray)
import qualified Streamly.Internal.Data.Array as Array
import qualified Streamly.Internal.Data.Array.Mut as MArray
import qualified Streamly.Internal.Data.Fold as Fold
import qualified Streamly.Internal.Data.Stream.StreamD as Stream
import qualified Streamly.Internal.Data.Stream as Stream
import Gauge
import Streamly.Benchmark.Common hiding (benchPureSrc)

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

@ -31,8 +31,8 @@ import Control.Monad.Catch (MonadCatch)
import Data.Functor.Identity (runIdentity)
import Data.Maybe (isJust)
import Data.Word (Word8)
import Streamly.Internal.Data.Stream.StreamD (Stream)
import Streamly.Internal.Data.Stream.StreamK (StreamK)
import Streamly.Internal.Data.Stream (Stream)
import Streamly.Internal.Data.StreamK (StreamK)
import System.IO (Handle)
import System.Random (randomRIO)
import Prelude hiding ()
@ -42,8 +42,8 @@ import qualified Streamly.Internal.Data.Array as Array
import qualified Streamly.Internal.Data.Stream.Chunked as ArrayStream
import qualified Streamly.Internal.Data.Fold as Fold
import qualified Streamly.Internal.Data.Parser as Parser
import qualified Streamly.Internal.Data.Stream.StreamD as Stream
import qualified Streamly.Internal.Data.Stream.StreamK as StreamK
import qualified Streamly.Internal.Data.Stream as Stream
import qualified Streamly.Internal.Data.StreamK as StreamK
import qualified Streamly.Internal.FileSystem.Handle as Handle
import qualified Streamly.Internal.Unicode.Stream as Unicode

4
benchmark/Streamly/Benchmark/Data/Fold.hs
View File

@ -25,7 +25,7 @@ import Data.IntMap.Strict (IntMap)
import Data.Monoid (Last(..), Sum(..))
import System.Random (randomRIO)
import Streamly.Internal.Data.Stream.StreamD (Stream)
import Streamly.Internal.Data.Stream (Stream)
import Streamly.Internal.Data.Fold (Fold(..))
import Streamly.Internal.Data.IsMap.HashMap ()
import Streamly.Internal.Data.Array.Mut (MutArray)
@ -35,7 +35,7 @@ import qualified Streamly.Data.Fold.Prelude as Fold
import qualified Streamly.Internal.Data.Fold.Container as FL
import qualified Streamly.Internal.Data.Unfold as Unfold
import qualified Streamly.Internal.Data.Pipe as Pipe
import qualified Streamly.Internal.Data.Stream.StreamD as Stream
import qualified Streamly.Internal.Data.Stream as Stream
import Gauge
import Streamly.Benchmark.Common

4
benchmark/Streamly/Benchmark/Data/Fold/Window.hs
View File

@ -4,13 +4,13 @@ module Main (main) where
import Control.DeepSeq (NFData)
import Streamly.Data.Fold (Fold)
import Streamly.Internal.Data.Stream.StreamD (Stream)
import Streamly.Internal.Data.Stream (Stream)
import System.Random (randomRIO)
import qualified Streamly.Data.Fold as Fold
import qualified Streamly.Internal.Data.Ring.Unboxed as Ring
import qualified Streamly.Internal.Data.Fold.Window as Window
import qualified Streamly.Internal.Data.Stream.StreamD as Stream
import qualified Streamly.Internal.Data.Stream as Stream
import Streamly.Benchmark.Common
import Gauge

4
benchmark/Streamly/Benchmark/Data/Parser.hs
View File

@ -34,7 +34,7 @@ import System.Random (randomRIO)
import Streamly.Internal.Data.Fold (Fold(..))
import Streamly.Internal.Data.Parser
(ParseError(..), Parser(..), Initial(..), Step(..))
import Streamly.Internal.Data.Stream.StreamD (Stream)
import Streamly.Internal.Data.Stream (Stream)
import Prelude hiding
(any, all, take, sequence, sequence_, sequenceA, takeWhile, dropWhile, span)
@ -48,7 +48,7 @@ import qualified Streamly.Internal.Data.Parser as PR
import qualified Streamly.Data.Stream as Stream
import qualified Streamly.Internal.Data.Producer as Producer
import qualified Streamly.Internal.Data.Producer.Source as Source
import qualified Streamly.Internal.Data.Stream.StreamD as Stream
import qualified Streamly.Internal.Data.Stream as Stream
import Gauge hiding (env)
import Streamly.Benchmark.Common

4
benchmark/Streamly/Benchmark/Data/Parser/ParserK.hs
View File

@ -23,7 +23,7 @@ import Streamly.Internal.Data.Fold.Type (Fold(..))
import Streamly.Data.StreamK (StreamK)
import Streamly.Internal.Data.Parser
(ParseError(..), Parser(..), Initial(..), Step(..))
import Streamly.Internal.Data.Stream.StreamD (Stream)
import Streamly.Internal.Data.Stream (Stream)
import System.Random (randomRIO)
import Prelude hiding
(any, all, take, sequence, sequence_, sequenceA, takeWhile)
@ -36,7 +36,7 @@ import qualified Streamly.Data.Fold as FL
import qualified Streamly.Internal.Data.Fold as Fold
import qualified Streamly.Data.Parser as PRD
import qualified Streamly.Data.ParserK as PR
import qualified Streamly.Internal.Data.Stream.StreamK as StreamK
import qualified Streamly.Internal.Data.StreamK as StreamK
import Gauge
import Streamly.Benchmark.Common

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

@ -36,7 +36,7 @@ import Streamly.Benchmark.Common
#ifdef FUSION_CHECK
import Data.Function ((&))
import Streamly.Data.Stream (Stream)
import qualified Streamly.Internal.Data.Stream.StreamD as Stream
import qualified Streamly.Internal.Data.Stream as Stream
import qualified Streamly.Internal.Data.Fold as Fold
import qualified Data.Foldable as Foldable
import Stream.Common

14
benchmark/Streamly/Benchmark/Data/Stream/Common.hs
View File

@ -90,15 +90,15 @@ import Streamly.Benchmark.Prelude
, concatStreamsWith
)
#else
import Streamly.Internal.Data.Stream.StreamD (Stream)
import qualified Streamly.Internal.Data.Stream.StreamD as D
import Streamly.Internal.Data.Stream (Stream)
import qualified Streamly.Internal.Data.Stream as D
#ifdef USE_STREAMK
import Streamly.Internal.Data.Stream.StreamK (StreamK)
import qualified Streamly.Internal.Data.Stream.StreamD as Stream
import qualified Streamly.Internal.Data.Stream.StreamK as StreamK
import Streamly.Internal.Data.StreamK (StreamK)
import qualified Streamly.Internal.Data.Stream as Stream
import qualified Streamly.Internal.Data.StreamK as StreamK
#else
import qualified Streamly.Internal.Data.Stream.StreamD as Stream
import qualified Streamly.Internal.Data.Stream.StreamD as StreamK
import qualified Streamly.Internal.Data.Stream as Stream
import qualified Streamly.Internal.Data.Stream as StreamK
#endif
#endif

10
benchmark/Streamly/Benchmark/Data/Stream/Eliminate.hs
View File

@ -37,7 +37,7 @@ import qualified Streamly.Internal.Data.Fold as Fold
#ifdef INSPECTION
import GHC.Types (SPEC(..))
import Test.Inspection
import qualified Streamly.Internal.Data.Stream.StreamD as D
import qualified Streamly.Internal.Data.Stream as D
#endif
#ifdef USE_PRELUDE
@ -47,13 +47,13 @@ import qualified Streamly.Internal.Data.Stream.IsStream as S
import qualified Streamly.Internal.Data.Stream.IsStream as StreamK
#else
import Stream.Common
import Streamly.Internal.Data.Stream.StreamD (Stream)
import qualified Streamly.Internal.Data.Stream.StreamD as S
import Streamly.Internal.Data.Stream (Stream)
import qualified Streamly.Internal.Data.Stream as S
#ifdef USE_STREAMK
import Streamly.Internal.Data.Stream.StreamK (StreamK)
import Streamly.Internal.Data.StreamK (StreamK)
import qualified Streamly.Data.StreamK as StreamK
#else
import qualified Streamly.Internal.Data.Stream.StreamD as StreamK
import qualified Streamly.Internal.Data.Stream as StreamK
#endif
#endif

4
benchmark/Streamly/Benchmark/Data/Stream/Exceptions.hs
View File

@ -41,7 +41,7 @@ import qualified Streamly.Internal.Data.Unfold.Exception as IUF
#ifdef USE_PRELUDE
import qualified Streamly.Internal.Data.Stream.IsStream as Stream
#else
import qualified Streamly.Internal.Data.Stream.StreamD as Stream
import qualified Streamly.Internal.Data.Stream as Stream
import qualified Streamly.Internal.Data.Stream.Exception.Lifted as Stream
#endif
@ -53,7 +53,7 @@ import Streamly.Benchmark.Common.Handle
#ifdef INSPECTION
import Test.Inspection
import qualified Streamly.Internal.Data.Stream.StreamD as D
import qualified Streamly.Internal.Data.Stream as D
#endif
#ifdef USE_PRELUDE

12
benchmark/Streamly/Benchmark/Data/Stream/Expand.hs
View File

@ -29,7 +29,7 @@ module Stream.Expand (benchmarks) where
import GHC.Types (SPEC(..))
import Test.Inspection
import qualified Streamly.Internal.Data.Stream.StreamD as D
import qualified Streamly.Internal.Data.Stream as D
#endif
import qualified Stream.Common as Common
@ -42,15 +42,15 @@ import Streamly.Benchmark.Prelude
( sourceFoldMapM, sourceFoldMapWith, sourceFoldMapWithM
, sourceFoldMapWithStream, concatFoldableWith, concatForFoldableWith)
#else
import qualified Streamly.Internal.Data.Stream.StreamD as S
import qualified Streamly.Internal.Data.Stream as S
#ifdef USE_STREAMK
import Streamly.Internal.Data.Stream.StreamD (Stream)
import Streamly.Internal.Data.Stream.StreamK (StreamK, CrossStreamK)
import Streamly.Internal.Data.Stream (Stream)
import Streamly.Internal.Data.StreamK (StreamK, CrossStreamK)
import qualified Control.Applicative as AP
import qualified Streamly.Internal.Data.Fold as Fold
import qualified Streamly.Internal.Data.Stream.StreamK as StreamK
import qualified Streamly.Internal.Data.StreamK as StreamK
#else
import qualified Streamly.Internal.Data.Stream.StreamD as StreamK
import qualified Streamly.Internal.Data.Stream as StreamK
#endif
#endif

6
benchmark/Streamly/Benchmark/Data/Stream/Generate.hs
View File

@ -31,11 +31,11 @@ import qualified Streamly.Prelude as S
import qualified Streamly.Internal.Data.Stream.IsStream as Stream
#else
import Stream.Common
import Streamly.Internal.Data.Stream.StreamD (Stream)
import qualified Streamly.Internal.Data.Stream.StreamD as Stream
import Streamly.Internal.Data.Stream (Stream)
import qualified Streamly.Internal.Data.Stream as Stream
#ifdef USE_STREAMK
import System.IO.Unsafe (unsafeInterleaveIO)
import qualified Streamly.Internal.Data.Stream.StreamK as StreamK
import qualified Streamly.Internal.Data.StreamK as StreamK
import qualified Stream.Common as Common
#endif
#endif

8
benchmark/Streamly/Benchmark/Data/Stream/Lift.hs
View File

@ -27,12 +27,12 @@ import qualified Streamly.Internal.Data.Fold as Fold
#ifdef USE_PRELUDE
import qualified Streamly.Internal.Data.Stream.IsStream as Stream
#else
import Streamly.Internal.Data.Stream.StreamD (Stream)
import qualified Streamly.Internal.Data.Stream.StreamD as Stream
import Streamly.Internal.Data.Stream (Stream)
import qualified Streamly.Internal.Data.Stream as Stream
#ifdef USE_STREAMK
import Stream.Common (benchIO, drain)
import Streamly.Internal.Data.Stream.StreamK (StreamK)
import qualified Streamly.Internal.Data.Stream.StreamK as StreamK
import Streamly.Internal.Data.StreamK (StreamK)
import qualified Streamly.Internal.Data.StreamK as StreamK
import qualified Control.Monad.State.Strict as State
#endif
#endif

10
benchmark/Streamly/Benchmark/Data/Stream/Reduce.hs
View File

@ -44,19 +44,19 @@ import Streamly.Benchmark.Prelude hiding
, transformComposeMapM, transformTeeMapM, transformZipMapM)
#else
import Streamly.Internal.Data.Stream.StreamD (Stream)
import qualified Streamly.Internal.Data.Stream.StreamD as S
import Streamly.Internal.Data.Stream (Stream)
import qualified Streamly.Internal.Data.Stream as S
#ifndef USE_STREAMLY_CORE
import qualified Streamly.Data.Stream.Prelude as S
import qualified Streamly.Internal.Data.Stream.Time as S
#endif
#ifdef USE_STREAMK
import Streamly.Internal.Data.Stream.StreamK (StreamK)
import Streamly.Internal.Data.StreamK (StreamK)
import qualified Streamly.Internal.Data.Parser as PR
import qualified Streamly.Internal.Data.Stream.StreamK as K
import qualified Streamly.Internal.Data.StreamK as K
#else
import qualified Streamly.Internal.Data.Stream.StreamD as K
import qualified Streamly.Internal.Data.Stream as K
#endif
#endif

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

@ -30,7 +30,7 @@ import System.Random (randomRIO)
import Prelude hiding (tail, mapM_, foldl, last, map, mapM, concatMap, zip)
import qualified Prelude as P
import qualified Streamly.Internal.Data.Stream.StreamD as S
import qualified Streamly.Internal.Data.Stream as S
import qualified Streamly.Internal.Data.Unfold as UF
import qualified Streamly.Internal.Data.Fold as FL

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

@ -34,7 +34,7 @@ import qualified Prelude as P
import qualified Data.List as List
import qualified Streamly.Internal.Data.Stream.StreamK.Type as S
import qualified Streamly.Internal.Data.Stream.StreamK as S
import qualified Streamly.Internal.Data.StreamK as S
import Gauge (bench, nfIO, bgroup, Benchmark, defaultMain)

4
benchmark/Streamly/Benchmark/Data/Stream/ToStreamK.hs
View File

@ -34,8 +34,8 @@ import qualified Prelude as P
-- import qualified Data.List as List
import qualified Streamly.Internal.Data.Stream.StreamK.Type as S
import qualified Streamly.Internal.Data.Stream.StreamK as S
import qualified Streamly.Internal.Data.Stream.StreamD as D
import qualified Streamly.Internal.Data.StreamK as S
import qualified Streamly.Internal.Data.Stream as D
import qualified Streamly.Internal.Data.Fold as Fold
import Gauge (bgroup, Benchmark, defaultMain)

8
benchmark/Streamly/Benchmark/Data/Stream/Transform.hs
View File

@ -43,8 +43,8 @@ import qualified Streamly.Internal.Data.Fold as Fold
import qualified Streamly.Internal.Data.Stream.IsStream as Stream
import Streamly.Internal.Data.Time.Units
#else
import Streamly.Internal.Data.Stream.StreamD (Stream)
import qualified Streamly.Internal.Data.Stream.StreamD as Stream
import Streamly.Internal.Data.Stream (Stream)
import qualified Streamly.Internal.Data.Stream as Stream
#ifndef USE_STREAMLY_CORE
import qualified Streamly.Internal.Data.Stream.Time as Stream
#endif
@ -53,8 +53,8 @@ import Control.DeepSeq (NFData(..))
import Data.Functor.Identity (Identity(..))
import qualified Prelude
import qualified Streamly.Internal.Data.Fold as Fold
import Streamly.Internal.Data.Stream.StreamK (StreamK)
import qualified Streamly.Internal.Data.Stream.StreamK as StreamK
import Streamly.Internal.Data.StreamK (StreamK)
import qualified Streamly.Internal.Data.StreamK as StreamK
#endif
#endif

6
benchmark/Streamly/Benchmark/Data/Unfold.hs
View File

@ -32,9 +32,9 @@ import qualified Streamly.FileSystem.Handle as FH
import qualified Streamly.Internal.Data.Fold as FL
import qualified Streamly.Internal.Data.Unfold as UF
import qualified Streamly.Internal.Data.Unfold.Exception as UF
import qualified Streamly.Internal.Data.Stream.StreamD as S
import qualified Streamly.Internal.Data.Stream.StreamD as D
import qualified Streamly.Internal.Data.Stream.StreamK as K
import qualified Streamly.Internal.Data.Stream as S
import qualified Streamly.Internal.Data.Stream as D
import qualified Streamly.Internal.Data.StreamK as K
import Gauge hiding (env)
import Prelude hiding (take, filter, zipWith, map, mapM, takeWhile)

4
benchmark/Streamly/Benchmark/FileSystem/Handle/Read.hs
View File

@ -35,7 +35,7 @@ import qualified Streamly.FileSystem.Handle as FH
import qualified Streamly.Internal.Data.Array as A
import qualified Streamly.Internal.Data.Array.Type as AT
import qualified Streamly.Internal.Data.Fold as FL
import qualified Streamly.Internal.Data.Stream.StreamD as IP
import qualified Streamly.Internal.Data.Stream as IP
import qualified Streamly.Internal.FileSystem.Handle as IFH
import qualified Streamly.Internal.Unicode.Stream as IUS
import qualified Streamly.Data.Stream.Prelude as S
@ -49,7 +49,7 @@ import Streamly.Benchmark.Common.Handle
import Streamly.Internal.Data.Stream.StreamD.Type (Step(..), FoldMany)
import qualified Streamly.Internal.Data.Array.Mut.Type as MA
import qualified Streamly.Internal.Data.Stream.StreamD as D
import qualified Streamly.Internal.Data.Stream as D
import qualified Streamly.Internal.Data.Unfold as IUF
import Test.Inspection

2
benchmark/Streamly/Benchmark/Prelude/Merge.hs
View File

@ -36,7 +36,7 @@ import Gauge
import GHC.Types (SPEC(..))
import Test.Inspection
import qualified Streamly.Internal.Data.Stream.StreamD as D
import qualified Streamly.Internal.Data.Stream as D
#endif
moduleName :: String

2
benchmark/Streamly/Benchmark/Prelude/WSerial.hs
View File

@ -35,7 +35,7 @@ import Gauge
import GHC.Types (SPEC(..))
import Test.Inspection
import qualified Streamly.Internal.Data.Stream.StreamD as D
import qualified Streamly.Internal.Data.Stream as D
#endif
moduleName :: String

2
benchmark/Streamly/Benchmark/Prelude/ZipSerial.hs
View File

@ -35,7 +35,7 @@ import Gauge
import GHC.Types (SPEC(..))
import Test.Inspection
import qualified Streamly.Internal.Data.Stream.StreamD as D
import qualified Streamly.Internal.Data.Stream as D
#endif
moduleName :: String

2
benchmark/Streamly/Benchmark/Unicode/Char.hs
View File

@ -24,7 +24,7 @@ import Streamly.Internal.Unicode.Char
import Streamly.Benchmark.Common (o_1_space_prefix)
import qualified Streamly.Internal.Data.Array as Array
import qualified Streamly.Internal.Data.Stream.StreamD as IsStream
import qualified Streamly.Internal.Data.Stream as IsStream
import qualified System.Directory as Dir
--------------------------------------------------------------------------------

2
benchmark/Streamly/Benchmark/Unicode/Stream.hs
View File

@ -27,7 +27,7 @@ import System.IO (Handle)
import qualified Streamly.Data.Array as Array
import qualified Streamly.Data.Fold as Fold
import qualified Streamly.Internal.Data.Stream.StreamD as Stream
import qualified Streamly.Internal.Data.Stream as Stream
import qualified Streamly.Internal.Data.Unfold as Unfold
import qualified Streamly.Internal.FileSystem.Handle as Handle
import qualified Streamly.Internal.Unicode.Array as UnicodeArr

2
benchmark/lib/Streamly/Benchmark/Common.hs
View File

@ -54,7 +54,7 @@ import Data.Functor.Identity (Identity, runIdentity)
import System.Random (randomRIO)
import qualified Streamly.Internal.Data.Fold as Fold
import qualified Streamly.Internal.Data.Stream.StreamD as S
import qualified Streamly.Internal.Data.Stream as S
import Gauge

2
core/src/DocTestDataStreamK.hs
View File

@ -16,6 +16,6 @@
For APIs that have not been released yet.
>>> import qualified Streamly.Internal.Data.Stream.StreamK as StreamK
>>> import qualified Streamly.Internal.Data.StreamK as StreamK
>>> import qualified Streamly.Internal.FileSystem.Dir as Dir
-}

8
core/src/Streamly/Data/Stream.hs
View File

@ -497,10 +497,7 @@ where
import Control.Monad.IO.Class (MonadIO)
import Data.Word (Word8)
import Streamly.Data.Array (Array)
import qualified Streamly.Internal.Data.Array.Type as Array
import qualified Streamly.Internal.Data.Stream.Chunked as ArrayStream
import Streamly.Internal.Data.Stream.StreamD
import Streamly.Internal.Data.Stream
import Prelude
hiding (filter, drop, dropWhile, take, takeWhile, zipWith, foldr,
foldl, map, mapM, mapM_, sequence, all, any, sum, product, elem,
@ -508,6 +505,9 @@ import Prelude
reverse, iterate, init, and, or, lookup, foldr1, (!!),
scanl, scanl1, repeat, replicate, concatMap, span)
import qualified Streamly.Internal.Data.Array.Type as Array
import qualified Streamly.Internal.Data.Stream.Chunked as ArrayStream
#include "DocTestDataStream.hs"
-- $overview

4
core/src/Streamly/Data/StreamK.hs
View File

@ -12,7 +12,7 @@
-- section in the "Streamly.Data.Stream" module to know when to use this
-- module.
--
-- Please refer to "Streamly.Internal.Data.Stream.StreamK" for more functions
-- Please refer to "Streamly.Internal.Data.StreamK" for more functions
-- that have not yet been released.
--
-- Some useful idioms:
@ -125,7 +125,7 @@ module Streamly.Data.StreamK
)
where
import Streamly.Internal.Data.Stream.StreamK
import Streamly.Internal.Data.StreamK
import Prelude hiding (reverse, zipWith, mapM, dropWhile, take)
#include "DocTestDataStreamK.hs"

4
core/src/Streamly/Internal/Console/Stdio.hs
View File

@ -47,12 +47,12 @@ import System.IO (stdin, stdout, stderr)
import Prelude hiding (read)
import Streamly.Internal.Data.Array.Type (Array(..))
import Streamly.Internal.Data.Stream.StreamD (Stream)
import Streamly.Internal.Data.Stream (Stream)
import Streamly.Internal.Data.Unfold (Unfold)
import Streamly.Internal.Data.Fold (Fold)
import qualified Streamly.Internal.Data.Array as Array
import qualified Streamly.Internal.Data.Stream.StreamD as Stream
import qualified Streamly.Internal.Data.Stream as Stream
(intersperseMSuffix)
import qualified Streamly.Internal.Data.Unfold as Unfold
import qualified Streamly.Internal.FileSystem.Handle as Handle

6
core/src/Streamly/Internal/Data/Array.hs
View File

@ -126,7 +126,7 @@ import Streamly.Internal.Data.Array.Type
(Array(..), length, asPtrUnsafe)
import Streamly.Internal.Data.Fold.Type (Fold(..))
import Streamly.Internal.Data.Producer.Type (Producer(..))
import Streamly.Internal.Data.Stream.StreamD (Stream)
import Streamly.Internal.Data.Stream (Stream)
import Streamly.Internal.Data.Tuple.Strict (Tuple3Fused'(..))
import Streamly.Internal.Data.Unfold.Type (Unfold(..))
import Streamly.Internal.System.IO (unsafeInlineIO)
@ -138,8 +138,8 @@ import qualified Streamly.Internal.Data.Fold as FL
import qualified Streamly.Internal.Data.Producer.Type as Producer
import qualified Streamly.Internal.Data.Producer as Producer
import qualified Streamly.Internal.Data.Ring.Unboxed as RB
import qualified Streamly.Internal.Data.Stream.StreamD as D
import qualified Streamly.Internal.Data.Stream.StreamD as Stream
import qualified Streamly.Internal.Data.Stream as D
import qualified Streamly.Internal.Data.Stream as Stream
import qualified Streamly.Internal.Data.Unfold as Unfold
#include "DocTestDataArray.hs"

4
core/src/Streamly/Internal/Data/Array/Mut.hs
View File

@ -20,10 +20,10 @@ where
import Control.Monad.IO.Class (MonadIO(..))
import Streamly.Internal.Data.Unbox (Unbox)
import Streamly.Internal.Data.Stream.StreamD (Stream)
import Streamly.Internal.Data.Stream (Stream)
import Streamly.Internal.Data.Unfold.Type (Unfold(..))
import qualified Streamly.Internal.Data.Stream.StreamD as D
import qualified Streamly.Internal.Data.Stream as D
import qualified Streamly.Internal.Data.Unfold as Unfold
import Prelude hiding (foldr, length, read, splitAt)

2
core/src/Streamly/Internal/Data/Array/Mut/Stream.hs
View File

@ -40,8 +40,8 @@ import Streamly.Internal.Data.Tuple.Strict (Tuple'(..))
import qualified Streamly.Internal.Data.Array.Mut.Type as MArray
import qualified Streamly.Internal.Data.Fold.Type as FL
import qualified Streamly.Internal.Data.Stream.StreamD as D
import qualified Streamly.Internal.Data.Parser as ParserD
import qualified Streamly.Internal.Data.Stream as D
-- | @chunksOf n stream@ groups the elements in the input stream into arrays of
-- @n@ elements each.

4
core/src/Streamly/Internal/Data/Pipe.hs
View File

@ -256,8 +256,8 @@ import Streamly.Internal.Data.Pipe.Type
-- import qualified Streamly.Internal.Data.Array.Type as A
-- import qualified Streamly.Data.Stream as S
-- import qualified Streamly.Internal.Data.Stream.StreamD as D
-- import qualified Streamly.Internal.Data.Stream.StreamK as K
-- import qualified Streamly.Internal.Data.Stream as D
-- import qualified Streamly.Internal.Data.StreamK as K
-- import qualified Streamly.Internal.Data.Stream.Common as P
------------------------------------------------------------------------------

4
core/src/Streamly/Internal/Data/Stream/Bottom.hs
View File

@ -79,8 +79,8 @@ import Streamly.Internal.Data.SVar.Type (defState)
import qualified Streamly.Internal.Data.Array.Type as A
import qualified Streamly.Internal.Data.Fold as Fold
import qualified Streamly.Internal.Data.Stream.StreamK as K
import qualified Streamly.Internal.Data.Stream.StreamD as D
import qualified Streamly.Internal.Data.StreamK as K
import qualified Streamly.Internal.Data.Stream as D
import Prelude hiding (take, takeWhile, drop, reverse, concatMap, map, zipWith)

8
core/src/Streamly/Internal/Data/Stream/Chunked.hs
View File

@ -80,8 +80,8 @@ import Streamly.Internal.Data.Array.Type (Array(..))
import Streamly.Internal.Data.Array.Mut.Type (MutArray)
import Streamly.Internal.Data.Fold.Chunked (ChunkFold(..))
import Streamly.Internal.Data.Parser (ParseError(..))
import Streamly.Internal.Data.Stream.StreamD (Stream)
import Streamly.Internal.Data.Stream.StreamK (StreamK, fromStream, toStream)
import Streamly.Internal.Data.Stream (Stream)
import Streamly.Internal.Data.StreamK (StreamK, fromStream, toStream)
import Streamly.Internal.Data.SVar.Type (adaptState, defState)
import Streamly.Internal.Data.Array.Mut.Type
(allocBytesToElemCount)
@ -97,8 +97,8 @@ import qualified Streamly.Internal.Data.Fold.Type as FL (Fold(..), Step(..))
import qualified Streamly.Internal.Data.Parser as PR
import qualified Streamly.Internal.Data.Parser as PRD
(Parser(..), Initial(..))
import qualified Streamly.Internal.Data.Stream.StreamD as D
import qualified Streamly.Internal.Data.Stream.StreamK as K
import qualified Streamly.Internal.Data.Stream as D
import qualified Streamly.Internal.Data.StreamK as K
-- XXX Since these are immutable arrays MonadIO constraint can be removed from
-- most places.

4
core/src/Streamly/Internal/Data/Stream/Eliminate.hs
View File

@ -87,9 +87,9 @@ import qualified Streamly.Internal.Data.Array.Type as Array
import qualified Streamly.Internal.Data.Fold as Fold
import qualified Streamly.Internal.Data.Parser as PRD
import qualified Streamly.Internal.Data.Parser.ParserK.Type as PRK
import qualified Streamly.Internal.Data.Stream.StreamD as D
import qualified Streamly.Internal.Data.Stream as D
import qualified Streamly.Internal.Data.Stream.StreamK.Type as K
import qualified Streamly.Internal.Data.Stream.StreamK as K
import qualified Streamly.Internal.Data.StreamK as K
import Streamly.Internal.Data.Stream.Bottom
import Streamly.Internal.Data.Stream.Type hiding (Stream)

2
core/src/Streamly/Internal/Data/Stream/Exception.hs
View File

@ -27,7 +27,7 @@ import Control.Monad.Catch (MonadCatch)
import Control.Monad.IO.Class (MonadIO)
import Streamly.Internal.Data.Stream.Type (Stream, fromStreamD, toStreamD)
import qualified Streamly.Internal.Data.Stream.StreamD as D
import qualified Streamly.Internal.Data.Stream as D
-- $setup
-- >>> :m

4
core/src/Streamly/Internal/Data/Stream/Expand.hs
View File

@ -147,8 +147,8 @@ import Streamly.Internal.Data.Stream.Type
, bindWith, concatMapWith, cons, nil)
import Streamly.Internal.Data.Unfold.Type (Unfold)
import qualified Streamly.Internal.Data.Stream.StreamD as D
import qualified Streamly.Internal.Data.Stream.StreamK as K (mergeBy, mergeByM)
import qualified Streamly.Internal.Data.Stream as D
import qualified Streamly.Internal.Data.StreamK as K (mergeBy, mergeByM)
import qualified Streamly.Internal.Data.Stream.StreamK.Type as K
import Prelude hiding (concat, concatMap, zipWith)

2
core/src/Streamly/Internal/Data/Stream/Generate.hs
View File

@ -84,7 +84,7 @@ import Streamly.Internal.Data.Unfold.Type (Unfold)
import qualified Streamly.Internal.Data.IORef.Unboxed as Unboxed
import qualified Streamly.Internal.Data.Stream.Bottom as Bottom
import qualified Streamly.Internal.Data.Stream.StreamD as D
import qualified Streamly.Internal.Data.Stream as D
import qualified Streamly.Internal.Data.Stream.StreamK.Type as K
import qualified Streamly.Internal.Data.Stream.Type as Stream
import qualified Streamly.Internal.Data.Stream.Transform as Stream (sequence)

4
core/src/Streamly/Internal/Data/Stream/Lift.hs
View File

@ -23,8 +23,8 @@ import Data.Functor.Identity (Identity (..))
import Streamly.Internal.Data.Stream.Type
(Stream, fromStreamD, toStreamD, fromStreamK, toStreamK)
import qualified Streamly.Internal.Data.Stream.StreamD as D
import qualified Streamly.Internal.Data.Stream.StreamK as K
import qualified Streamly.Internal.Data.Stream as D
import qualified Streamly.Internal.Data.StreamK as K
-- $setup
-- >>> :m

2
core/src/Streamly/Internal/Data/Stream/Reduce.hs
View File

@ -69,7 +69,7 @@ import Streamly.Internal.Data.Unbox (Unbox)
import qualified Streamly.Internal.Data.Array.Type as Array
import qualified Streamly.Internal.Data.Parser as ParserD
import qualified Streamly.Internal.Data.Stream.StreamD as D
import qualified Streamly.Internal.Data.Stream as D
import Prelude hiding (concatMap, map)

2
core/src/Streamly/Internal/Data/Stream/StreamK/Transformer.hs
View File

@ -18,7 +18,7 @@ where
import Control.Monad.Trans.Class (MonadTrans(lift))
import Control.Monad.Trans.State.Strict (StateT)
import Streamly.Internal.Data.Stream.StreamK
import Streamly.Internal.Data.StreamK
(StreamK, nil, cons, uncons, concatEffect)
import qualified Control.Monad.Trans.State.Strict as State

6
core/src/Streamly/Internal/Data/Stream/StreamK.hs → core/src/Streamly/Internal/Data/StreamK.hs
View File

@ -1,6 +1,6 @@
{-# LANGUAGE CPP #-}
-- |
-- Module : Streamly.Internal.Data.Stream.StreamK
-- Module : Streamly.Internal.Data.StreamK
-- Copyright : (c) 2017 Composewell Technologies
--
-- License : BSD3
@ -8,7 +8,7 @@
-- Stability : experimental
-- Portability : GHC
--
module Streamly.Internal.Data.Stream.StreamK
module Streamly.Internal.Data.StreamK
(
-- * Setup
-- | To execute the code examples provided in this module in ghci, please
@ -208,7 +208,7 @@ import qualified Streamly.Internal.Data.Fold.Type as FL
import qualified Streamly.Internal.Data.Parser as Parser
import qualified Streamly.Internal.Data.Parser.ParserD.Type as PR
import qualified Streamly.Internal.Data.Parser.ParserK.Type as ParserK
import qualified Streamly.Internal.Data.Stream.StreamD as Stream
import qualified Streamly.Internal.Data.Stream as Stream
import qualified Prelude
import Prelude

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

@ -136,7 +136,7 @@ import qualified Streamly.Internal.Data.Stream.Chunked as AS
import qualified Streamly.Internal.Data.Array.Mut.Type as MArray
import qualified Streamly.Internal.Data.Refold.Type as Refold
import qualified Streamly.Internal.Data.Fold.Type as FL(refoldMany)
import qualified Streamly.Internal.Data.Stream.StreamD as S
import qualified Streamly.Internal.Data.Stream as S
import qualified Streamly.Internal.Data.Stream.StreamD.Type as D
(Stream(..), Step(..))
import qualified Streamly.Internal.Data.Unfold as UF

8
core/src/Streamly/Internal/Serialize/ToBytes.hs
View File

@ -47,12 +47,12 @@ import Data.Char (ord)
import Data.Int (Int8, Int16, Int32, Int64)
import Data.Word (Word8, Word16, Word32, Word64)
import GHC.Float (castDoubleToWord64, castFloatToWord32)
import Streamly.Internal.Data.Stream.StreamD (Stream)
import Streamly.Internal.Data.Stream.StreamD (Step(..))
import Streamly.Internal.Data.Stream (Stream)
import Streamly.Internal.Data.Stream (Step(..))
import Streamly.Internal.Unicode.Stream (readCharUtf8)
import qualified Streamly.Internal.Data.Stream.StreamD as Stream
import qualified Streamly.Internal.Data.Stream.StreamD as D
import qualified Streamly.Internal.Data.Stream as Stream
import qualified Streamly.Internal.Data.Stream as D
-- XXX Use StreamD directly?

8
core/src/Streamly/Internal/Unicode/Stream.hs
View File

@ -104,8 +104,8 @@ import System.IO.Unsafe (unsafePerformIO)
import Streamly.Internal.Data.Array.Type (Array(..))
import Streamly.Internal.Data.Array.Mut.Type (MutableByteArray)
import Streamly.Internal.Data.Fold (Fold)
import Streamly.Internal.Data.Stream.StreamD (Stream)
import Streamly.Internal.Data.Stream.StreamD (Step (..))
import Streamly.Internal.Data.Stream (Stream)
import Streamly.Internal.Data.Stream (Step (..))
import Streamly.Internal.Data.SVar.Type (adaptState)
import Streamly.Internal.Data.Tuple.Strict (Tuple'(..))
import Streamly.Internal.Data.Unbox (peekWith)
@ -117,8 +117,8 @@ import qualified Streamly.Data.Unfold as Unfold
import qualified Streamly.Internal.Data.Array.Type as Array
import qualified Streamly.Internal.Data.Parser as Parser (Parser)
import qualified Streamly.Internal.Data.Parser as ParserD
import qualified Streamly.Internal.Data.Stream.StreamD as Stream
import qualified Streamly.Internal.Data.Stream.StreamD as D
import qualified Streamly.Internal.Data.Stream as Stream
import qualified Streamly.Internal.Data.Stream as D
import Prelude hiding (lines, words, unlines, unwords)

2
core/streamly-core.cabal
View File

@ -311,7 +311,7 @@ library
, Streamly.Internal.Data.Array.Generic.Mut.Type
-- streamly-core-streams
, Streamly.Internal.Data.Stream.StreamK
, Streamly.Internal.Data.StreamK
-- StreamD depends on streamly-array-types
, Streamly.Internal.Data.Stream.StreamD.Generate
, Streamly.Internal.Data.Stream.StreamD.Eliminate

2
docs/Developer/optimization-guidelines.md
View File

@ -244,7 +244,7 @@ We also use INLINE [3] in some cases.
The combinators in `Streamly.Prelude` are defined in terms of combinators in
`Streamly.Internal.Data.Stream.StreamD` (Direct style streams) or
`Streamly.Internal.Data.Stream.StreamK` (CPS style streams). We convert the
`Streamly.Internal.Data.StreamK` (CPS style streams). We convert the
stream from `StreamD` to `StreamK` representation or vice versa in some cases.
Most operations use the StreamD representation, however, stream append

4
docs/User/Project/Upgrading.md
View File

@ -153,8 +153,8 @@ module. You can use the following equivalent definitions:
>>> and = Stream.fold Fold.and
>>> all p = Stream.fold (Fold.all p)
>>> (!!) i = Stream.fold (Fold.index i)
>>> tail = Streamly.Internal.Data.Stream.StreamK.tail
>>> init = Streamly.Internal.Data.Stream.StreamK.init
>>> tail = Streamly.Internal.Data.StreamK.tail
>>> init = Streamly.Internal.Data.StreamK.init
```
Mapping functions:

2
src/Streamly/Internal/Data/SmallArray.hs
View File

@ -53,7 +53,7 @@ import Streamly.Data.Stream (Stream)
import Streamly.Internal.Data.Tuple.Strict (Tuple'(..))
import Streamly.Internal.Data.Unfold.Type (Unfold(..))
import qualified Streamly.Internal.Data.Stream.StreamD as D
import qualified Streamly.Internal.Data.Stream as D
import qualified Streamly.Internal.Data.Fold.Type as FL
(Fold (..), Step (Done, Partial))

8
src/Streamly/Internal/Data/Stream/Concurrent.hs
View File

@ -111,12 +111,12 @@ import Streamly.Internal.Data.Stream.Channel.Types
)
import Streamly.Internal.Data.Stream.Channel.Worker (sendWithDoorBell)
import Streamly.Internal.Data.Stream.StreamD.Type (Stream)
import Streamly.Internal.Data.Stream.StreamD (Step(..))
import Streamly.Internal.Data.Stream (Step(..))
import qualified Streamly.Internal.Data.IORef.Unboxed as Unboxed
import qualified Streamly.Internal.Data.Stream.StreamD as Stream
import qualified Streamly.Internal.Data.Stream.StreamD as D
import qualified Streamly.Internal.Data.Stream.StreamK as K
import qualified Streamly.Internal.Data.Stream as Stream
import qualified Streamly.Internal.Data.Stream as D
import qualified Streamly.Internal.Data.StreamK as K
import qualified Streamly.Internal.Data.Stream.StreamK.Type as K
import Prelude hiding (mapM, sequence, concat, concatMap, zipWith)

4
src/Streamly/Internal/Data/Stream/Concurrent/Channel.hs
View File

@ -51,7 +51,7 @@ module Streamly.Internal.Data.Stream.Concurrent.Channel
where
import Streamly.Internal.Control.Concurrent (MonadAsync)
import Streamly.Internal.Data.Stream.StreamD (Stream)
import Streamly.Internal.Data.Stream (Stream)
import Streamly.Internal.Data.Stream.Concurrent.Channel.Operations
(fromChannel, fromChannelK, toChannel, toChannelK)
@ -59,7 +59,7 @@ import qualified Streamly.Internal.Data.Stream.Concurrent.Channel.Append
as Append
import qualified Streamly.Internal.Data.Stream.Concurrent.Channel.Interleave
as Interleave
import qualified Streamly.Internal.Data.Stream.StreamK as K
import qualified Streamly.Internal.Data.StreamK as K
import Streamly.Internal.Data.Stream.Concurrent.Channel.Type
import Streamly.Internal.Data.Stream.Channel.Types

2
src/Streamly/Internal/Data/Stream/Concurrent/Channel/Operations.hs
View File

@ -38,7 +38,7 @@ import Streamly.Internal.Data.Stream.StreamD.Type (Stream)
import Streamly.Internal.Data.Time.Clock (Clock(Monotonic), getTime)
import System.Mem (performMajorGC)
import qualified Streamly.Internal.Data.Stream.StreamD as Stream
import qualified Streamly.Internal.Data.Stream as Stream
import qualified Streamly.Internal.Data.Stream.StreamD.Type as D
import qualified Streamly.Internal.Data.Stream.StreamK.Type as K

4
src/Streamly/Internal/Data/Stream/Exception/Lifted.hs
View File

@ -38,11 +38,11 @@ import Streamly.Internal.Control.Concurrent
import Streamly.Internal.Data.Stream.StreamD.Type (Stream)
import Streamly.Internal.Data.IOFinalizer.Lifted
(newIOFinalizer, runIOFinalizer, clearingIOFinalizer)
import Streamly.Internal.Data.Stream.StreamD (Step(..))
import Streamly.Internal.Data.Stream (Step(..))
import qualified Control.Monad.Catch as MC
import qualified Data.Map.Strict as Map
import qualified Streamly.Internal.Data.Stream.StreamD as D
import qualified Streamly.Internal.Data.Stream as D
-- $setup
-- >>> :m

2
src/Streamly/Internal/Data/Stream/IsStream.hs
View File

@ -39,7 +39,7 @@ import Streamly.Internal.Data.Stream.IsStream.Type
hiding (cmpBy, drain, eqBy, foldl', fold, toList, toStream
, fromEffect, fromPure, repeat, fromStream)
import qualified Streamly.Internal.Data.Stream.StreamD as D
import qualified Streamly.Internal.Data.Stream as D
{-# INLINE fromStream #-}
fromStream :: (IsStream t, Monad m) => D.Stream m a -> t m a

2
src/Streamly/Internal/Data/Stream/IsStream/Common.hs
View File

@ -87,7 +87,7 @@ import qualified Streamly.Internal.Data.Stream.IsStream.Type as IsStream
import qualified Streamly.Internal.Data.Stream.Parallel as Par
import qualified Streamly.Internal.Data.Stream.StreamK.Type as K
(fromPure, fromEffect, repeatMWith, reverse)
import qualified Streamly.Internal.Data.Stream.StreamD as D
import qualified Streamly.Internal.Data.Stream as D
(repeatM, timesWith, foldAddLazy, map, scanlMAfter', postscanlMAfter'
, postscanlM', take, takeWhile, takeEndBy, drop, findIndices
, fromStreamK, toStreamK, concatMapM, concatMap, foldManyPost, splitOnSeq

2
src/Streamly/Internal/Data/Stream/IsStream/Eliminate.hs
View File

@ -172,7 +172,7 @@ import qualified Streamly.Internal.Data.Fold as FL
import qualified Streamly.Internal.Data.Parser as PRD
-- import qualified Streamly.Internal.Data.Parser.ParserK.Type as PRK
import qualified Streamly.Internal.Data.Stream.IsStream.Type as IsStream
import qualified Streamly.Internal.Data.Stream.StreamD as D
import qualified Streamly.Internal.Data.Stream as D
(foldr1, foldlT, foldlM', mapM_, null, head, headElse, last, elem
, notElem, all, any, minimum, minimumBy, maximum, maximumBy, the, lookup
, find, findM, toListRev, isPrefixOf, isSubsequenceOf, stripPrefix, (!!)

2
src/Streamly/Internal/Data/Stream/IsStream/Enumeration.hs
View File

@ -65,7 +65,7 @@ import Data.Functor.Identity (Identity(..))
import Streamly.Internal.Data.Stream.IsStream.Type (IsStream(..), fromStreamD)
import qualified Streamly.Internal.Data.Stream.IsStream.Type as IsStream
import qualified Streamly.Internal.Data.Stream.StreamD as D
import qualified Streamly.Internal.Data.Stream as D
( enumerateFromNum
, enumerateFromThenNum
, enumerateFromThenToIntegral

4
src/Streamly/Internal/Data/Stream/IsStream/Expand.hs
View File

@ -178,12 +178,12 @@ import Streamly.Data.Unfold (Unfold)
import qualified Streamly.Internal.Data.Stream.IsStream.Type as IsStream
import qualified Streamly.Internal.Data.Stream.Parallel as Par
import qualified Streamly.Internal.Data.Stream.Serial as Serial
import qualified Streamly.Internal.Data.Stream.StreamD as D
import qualified Streamly.Internal.Data.Stream as D
(append, interleave, interleaveFstSuffix, interleaveFst, interleaveMin
, roundRobin, mergeByM, unfoldMany, unfoldInterleave, intersperse
, unfoldRoundRobin, interpose, interposeSuffix, gintercalate
, gintercalateSuffix, intersperseMSuffix)
import qualified Streamly.Internal.Data.Stream.StreamK as K (mergeBy, mergeByM)
import qualified Streamly.Internal.Data.StreamK as K (mergeBy, mergeByM)
import qualified Streamly.Internal.Data.Stream.StreamK.Type as K
(interleave, append, mergeMapWith)
import qualified Streamly.Internal.Data.Stream.ZipAsync as ZipAsync

2
src/Streamly/Internal/Data/Stream/IsStream/Generate.hs
View File

@ -110,7 +110,7 @@ import qualified Streamly.Internal.Data.IORef.Unboxed as Unboxed
import qualified Streamly.Internal.Data.Stream.IsStream.Type as IsStream
import qualified Streamly.Internal.Data.Stream.Parallel as Par
import qualified Streamly.Internal.Data.Stream.Serial as Serial
import qualified Streamly.Internal.Data.Stream.StreamD as D
import qualified Streamly.Internal.Data.Stream as D
(unfold, unfoldr, toStreamK, unfoldr, repeat, replicate, replicateM
, fromIndices, fromIndicesM, iterate, iterateM, toStreamK, fromListM
, fromListM)

2
src/Streamly/Internal/Data/Stream/IsStream/Lift.hs
View File

@ -34,7 +34,7 @@ import Streamly.Internal.Data.Stream.IsStream.Type
(IsStream(..), fromStreamD, toStreamD)
import Streamly.Internal.Data.Stream.Serial (SerialT)
import qualified Streamly.Internal.Data.Stream.StreamD as D
import qualified Streamly.Internal.Data.Stream as D
(morphInner, liftInner, runReaderT, evalStateT, runStateT)
------------------------------------------------------------------------------

2
src/Streamly/Internal/Data/Stream/IsStream/Reduce.hs
View File

@ -191,7 +191,7 @@ import qualified Streamly.Internal.Data.Fold as FL
import qualified Streamly.Internal.Data.IsMap as IsMap
import qualified Streamly.Internal.Data.Parser as PRD (Parser(..))
import qualified Streamly.Internal.Data.Stream.IsStream.Type as IsStream
import qualified Streamly.Internal.Data.Stream.StreamD as D
import qualified Streamly.Internal.Data.Stream as D
( foldMany
, groupsOf
, refoldMany

2
src/Streamly/Internal/Data/Stream/IsStream/Top.hs
View File

@ -83,7 +83,7 @@ import qualified Streamly.Internal.Data.Stream.IsStream.Expand as Stream
import qualified Streamly.Internal.Data.Stream.IsStream.Reduce as Stream
import qualified Streamly.Internal.Data.Stream.IsStream.Transform as Stream
import qualified Streamly.Internal.Data.Stream.IsStream.Type as IsStream
import qualified Streamly.Internal.Data.Stream.StreamD as StreamD
import qualified Streamly.Internal.Data.Stream as StreamD
import Prelude hiding (Foldable(..), filter, zipWith, concatMap, concat)

2
src/Streamly/Internal/Data/Stream/IsStream/Transform.hs
View File

@ -256,7 +256,7 @@ import qualified Streamly.Data.Fold as FL
import qualified Streamly.Internal.Data.Stream.Concurrent as Concur
import qualified Streamly.Internal.Data.Stream.Parallel as Par
import qualified Streamly.Internal.Data.Stream.Serial as Serial
import qualified Streamly.Internal.Data.Stream.StreamD as D
import qualified Streamly.Internal.Data.Stream as D
(transform, foldrT, tap, tapOffsetEvery, mapM, scan
, scanMany, postscan, scanlx', scanlM', scanl', postscanl', prescanl'
, prescanlM', scanl1M', scanl1', filter, filterM, uniq, deleteBy, takeWhileM

2
src/Streamly/Internal/Data/Stream/IsStream/Type.hs
View File

@ -127,7 +127,7 @@ import qualified Streamly.Internal.Data.Stream.StreamK.Type as K
(StreamK(..), cons, fromEffect
, nil, fromPure, bindWith, drain
, fromFoldable, nilM, repeat)
import qualified Streamly.Internal.Data.Stream.StreamK as StreamK
import qualified Streamly.Internal.Data.StreamK as StreamK
import qualified Streamly.Internal.Data.Stream.Serial as Stream
(fromStreamK, toStreamK)
import qualified Streamly.Internal.Data.Stream.Zip as Zip

2
src/Streamly/Internal/Data/Stream/Time.hs
View File

@ -78,7 +78,7 @@ import qualified Streamly.Data.Stream as Stream
import qualified Streamly.Data.Unfold as Unfold
import qualified Streamly.Internal.Data.Fold as Fold (Step(..))
import qualified Streamly.Internal.Data.IsMap as IsMap
import qualified Streamly.Internal.Data.Stream.StreamD as Stream
import qualified Streamly.Internal.Data.Stream as Stream
( scanlMAfter'
, timeIndexed
, timestamped

2
src/Streamly/Internal/Data/Stream/Zip.hs
View File

@ -50,7 +50,7 @@ import Streamly.Internal.Data.Stream.StreamK.Type (Stream)
import qualified Streamly.Internal.Data.Stream.Common as P
import qualified Streamly.Internal.Data.Stream.StreamK.Type as K
import qualified Streamly.Internal.Data.Stream.StreamD as D
import qualified Streamly.Internal.Data.Stream as D
import qualified Streamly.Internal.Data.Stream.Serial as Serial
import Prelude hiding (map, repeat, zipWith)

4
src/Streamly/Internal/Data/Stream/Zip/Concurrent.hs
View File

@ -18,10 +18,10 @@ module Streamly.Internal.Data.Stream.Zip.Concurrent
)
where
import Streamly.Internal.Data.Stream.StreamD (Stream)
import Streamly.Internal.Data.Stream (Stream)
import Streamly.Internal.Data.Stream.Concurrent (MonadAsync, parZipWith)
import qualified Streamly.Internal.Data.Stream.StreamD as Stream (repeat)
import qualified Streamly.Internal.Data.Stream as Stream (repeat)
import Prelude hiding (map, repeat, zipWith)
-- $setup

4
src/Streamly/Internal/Data/Stream/ZipAsync.hs
View File

@ -25,9 +25,9 @@ where
import Streamly.Internal.Control.Concurrent (MonadAsync)
import Streamly.Internal.Data.Stream.StreamK.Type (Stream)
import qualified Streamly.Internal.Data.Stream.StreamK as K
import qualified Streamly.Internal.Data.StreamK as K
(mkStream, foldStream, zipWithM, consM)
import qualified Streamly.Internal.Data.Stream.StreamD as D (fromStreamK)
import qualified Streamly.Internal.Data.Stream as D (fromStreamK)
import qualified Streamly.Internal.Data.Stream.Serial as Serial
import qualified Streamly.Internal.Data.Stream.SVar.Eliminate as SVar
import qualified Streamly.Internal.Data.Stream.SVar.Generate as SVar

2
src/Streamly/Internal/FileSystem/Event.hs
View File

@ -48,7 +48,7 @@ where
import Data.List.NonEmpty (NonEmpty)
import Data.Word (Word8)
import Streamly.Internal.Data.Array (Array)
import Streamly.Internal.Data.Stream.StreamD (Stream)
import Streamly.Internal.Data.Stream (Stream)
#if defined(CABAL_OS_DARWIN)
import Streamly.Internal.FileSystem.Event.Darwin (Event)

4
src/Streamly/Internal/FileSystem/Event/Linux.hs
View File

@ -171,7 +171,7 @@ import Foreign.Storable (peek, peekByteOff, sizeOf)
import GHC.IO.Device (IODeviceType(Stream))
import GHC.IO.FD (fdFD, mkFD)
import GHC.IO.Handle.FD (mkHandleFromFD)
import Streamly.Internal.Data.Stream.StreamD (Stream)
import Streamly.Internal.Data.Stream (Stream)
import Streamly.Internal.Data.Parser (Parser)
import Streamly.Internal.Data.Array.Type (Array(..), byteLength)
import System.Directory (doesDirectoryExist)
@ -184,7 +184,7 @@ import qualified Streamly.Internal.Data.Array as A
import qualified Streamly.Data.Fold as FL
import qualified Streamly.Internal.Data.Parser as PR
(takeEQ, fromEffect, fromFold)
import qualified Streamly.Internal.Data.Stream.StreamD as S
import qualified Streamly.Internal.Data.Stream as S
import qualified Streamly.Internal.FileSystem.Dir as Dir
import qualified Streamly.Internal.FileSystem.Handle as FH
import qualified Streamly.Internal.Unicode.Stream as U

2
src/Streamly/Internal/FileSystem/FD.hs
View File

@ -148,7 +148,7 @@ import qualified Streamly.Data.Fold as FL
import qualified Streamly.Internal.Data.Array.Mut as MArray
(MutArray(..), newPinnedBytes, asPtrUnsafe)
import qualified Streamly.Internal.Data.Stream.Chunked as AS
import qualified Streamly.Internal.Data.Stream.StreamD as S
import qualified Streamly.Internal.Data.Stream as S
import qualified Streamly.Internal.Data.Stream.StreamD.Type as D
(Stream(..), Step(..))
import qualified Streamly.Internal.Data.Stream.StreamK.Type as K (mkStream)

2
src/Streamly/Internal/Network/Inet/TCP.hs
View File

@ -124,7 +124,7 @@ import qualified Streamly.Data.Unfold as UF
import qualified Streamly.Internal.Data.Array.Type as A
import qualified Streamly.Internal.Data.Unfold as UF (first, bracketIO)
import qualified Streamly.Internal.Data.Fold.Type as FL (Step(..), reduce)
import qualified Streamly.Internal.Data.Stream.StreamD as S
import qualified Streamly.Internal.Data.Stream as S
import qualified Streamly.Internal.Data.Stream.Exception.Lifted as S
import qualified Streamly.Internal.Network.Socket as ISK

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

@ -100,7 +100,7 @@ import qualified Streamly.Internal.Data.Array.Type as A
(unsafeFreeze, asPtrUnsafe, byteLength, writeNUnsafe, chunksOf)
import qualified Streamly.Internal.Data.Array.Mut as MArray
(MutArray(..), newPinnedBytes, asPtrUnsafe)
import qualified Streamly.Internal.Data.Stream.StreamD as S
import qualified Streamly.Internal.Data.Stream as S
import qualified Streamly.Internal.Data.Stream.StreamD.Type as D
(Stream(..), Step(..))
import qualified Streamly.Data.Unfold as UF

2
src/Streamly/Internal/System/IOVec.hs
View File

@ -36,7 +36,7 @@ import Streamly.Internal.Data.Array.Mut.Type (Array(..))
import qualified Streamly.Internal.Data.Array.Type as Array
import qualified Streamly.Internal.Data.Array.Mut.Type as MArray
import qualified Streamly.Internal.Data.Stream.StreamD as D
import qualified Streamly.Internal.Data.Stream as D
-}
#endif

4
src/Streamly/Internal/Unicode/Char.hs
View File

@ -35,9 +35,9 @@ where
import Data.Char (isAsciiUpper, isAsciiLower, chr, ord)
import Unicode.Char (DecomposeMode(..))
import Streamly.Internal.Data.Stream.StreamD (Stream(..), Step (..))
import Streamly.Internal.Data.Stream (Stream(..), Step (..))
import qualified Streamly.Internal.Data.Stream.StreamD as Stream (Stream)
import qualified Streamly.Internal.Data.Stream as Stream (Stream)
import qualified Unicode.Char as Char

2
test/Streamly/Test/Data/Parser/ParserD.hs
View File

@ -20,7 +20,7 @@ import qualified Streamly.Internal.Data.Parser as P
import qualified Streamly.Internal.Data.Producer.Source as Source
import qualified Streamly.Internal.Data.Producer as Producer
import qualified Streamly.Internal.Data.Stream as S
import qualified Streamly.Internal.Data.Stream.StreamD as D
import qualified Streamly.Internal.Data.Stream as D
import qualified Streamly.Internal.Data.Unfold as Unfold
import qualified Test.Hspec as H

4
test/Streamly/Test/Data/Unfold.hs
View File

@ -16,8 +16,8 @@ import qualified Prelude
import qualified Streamly.Internal.Data.Fold as Fold
import qualified Streamly.Internal.Data.Unfold as UF
import qualified Streamly.Internal.Data.Stream as S
import qualified Streamly.Internal.Data.Stream.StreamD as D
import qualified Streamly.Internal.Data.Stream.StreamK as K
import qualified Streamly.Internal.Data.Stream as D
import qualified Streamly.Internal.Data.StreamK as K
import Control.Monad.Trans.State.Strict
import Data.Functor.Identity

2
test/Streamly/Test/Prelude/Serial.hs
View File

@ -49,7 +49,7 @@ import qualified Streamly.Data.Stream.Prelude as S
import qualified Streamly.Internal.Data.Fold as FL
import qualified Streamly.Internal.Data.Unfold as UF
import qualified Streamly.Internal.Data.Stream as IS
import qualified Streamly.Internal.Data.Stream.StreamK as K
import qualified Streamly.Internal.Data.StreamK as K
import qualified Streamly.Data.Array as A
import qualified Streamly.Internal.Data.Parser as Parser
import qualified Streamly.Prelude as SP

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

@ -21,7 +21,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.Stream.StreamD as Stream
import qualified Streamly.Internal.Data.Stream as Stream
import qualified Streamly.Unicode.Stream as SS
import qualified Streamly.Internal.Unicode.Stream as IUS
import qualified Streamly.Internal.Unicode.Array as IUA