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

Hide Internal StreamD submodules

Browse Source
This commit is contained in:
Ranjeet Kumar Ranjan 2023-08-03 09:28:39 +05:30 committed by Harendra Kumar
parent 82054c8750
commit d304fb842a
26 changed files with 59 additions and 57 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

@ -54,7 +54,7 @@ import Control.Monad.IO.Class (MonadIO)
#ifdef INSPECTION
import Streamly.Internal.Data.Unbox (Unbox)
import Streamly.Internal.Data.Stream.StreamD.Type (Step(..))
import Streamly.Internal.Data.Stream (Step(..))
import Test.Inspection
#endif

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

@ -41,7 +41,7 @@ import Streamly.Benchmark.Common
import Streamly.Benchmark.Common.Handle
#ifdef INSPECTION
import Streamly.Internal.Data.Stream.StreamD.Type (Step(..))
import Streamly.Internal.Data.Stream (Step(..))
import qualified Streamly.Internal.Data.MutArray.Type as MA
import qualified Streamly.Internal.Data.Unfold as IUF

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

@ -46,7 +46,7 @@ import Prelude hiding (last, length)
import Streamly.Benchmark.Common.Handle
#ifdef INSPECTION
import Streamly.Internal.Data.Stream.StreamD.Type (Step(..), FoldMany)
import Streamly.Internal.Data.Stream (Step(..), FoldMany)
import qualified Streamly.Internal.Data.MutArray.Type as MA
import qualified Streamly.Internal.Data.Stream as D

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

@ -38,9 +38,9 @@ import Gauge hiding (env)
import Streamly.Benchmark.Common.Handle
#ifdef INSPECTION
import Streamly.Internal.Data.Stream.StreamD.Type (Step(..))
import Streamly.Internal.Data.Stream (Step(..))
import qualified Streamly.Internal.Data.Stream.StreamD.Type as D
import qualified Streamly.Internal.Data.Stream as D
import qualified Streamly.Internal.Data.Tuple.Strict as Strict
import qualified Streamly.Internal.Data.Stream.MutChunked as MAS
import qualified Streamly.Internal.Data.Array.Type as AT

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

@ -39,7 +39,7 @@ import Streamly.Benchmark.Common.Handle
#ifdef INSPECTION
import Streamly.Internal.Data.Unbox (Unbox)
import Streamly.Internal.Data.Stream.StreamD.Type (Step(..))
import Streamly.Internal.Data.Stream.StreamD (Step(..))
import qualified Streamly.Internal.Data.Fold.Type as Fold
import qualified Streamly.Internal.Data.Tuple.Strict as Strict
import qualified Streamly.Internal.Data.Array.Type as Array

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

@ -137,7 +137,7 @@ 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)
import qualified Streamly.Internal.Data.Stream as S
import qualified Streamly.Internal.Data.Stream.StreamD.Type as D
import qualified Streamly.Internal.Data.Stream as D
(Stream(..), Step(..))
import qualified Streamly.Internal.Data.Unfold as UF
import qualified Streamly.Internal.Data.Stream.StreamK.Type as K (mkStream)

28
core/streamly-core.cabal
View File

@ -290,8 +290,6 @@ library
, Streamly.Internal.Data.Fold.Step
, Streamly.Internal.Data.Refold.Type
, Streamly.Internal.Data.Fold.Type
, Streamly.Internal.Data.Stream.StreamD.Step
, Streamly.Internal.Data.Stream.StreamD.Type
, Streamly.Internal.Data.Unfold.Type
, Streamly.Internal.Data.Producer.Type
, Streamly.Internal.Data.Producer
@ -316,13 +314,6 @@ library
-- streamly-core-streams
, Streamly.Internal.Data.StreamK
-- StreamD depends on streamly-array-types
, Streamly.Internal.Data.Stream.StreamD.Generate
, Streamly.Internal.Data.Stream.StreamD.Eliminate
, Streamly.Internal.Data.Stream.StreamD.Nesting
, Streamly.Internal.Data.Stream.StreamD.Transform
, Streamly.Internal.Data.Stream.StreamD.Exception
, Streamly.Internal.Data.Stream.StreamD.Lift
, Streamly.Internal.Data.Stream.StreamD.Top
, Streamly.Internal.Data.Stream.StreamD
, Streamly.Internal.Data.Stream.Common
, Streamly.Internal.Data.Stream
@ -332,7 +323,6 @@ library
-- streamly-core-data
, Streamly.Internal.Data.Builder
, Streamly.Internal.Data.Unfold
, Streamly.Internal.Data.Unfold.Enumeration
, Streamly.Internal.Data.Fold.Tee
, Streamly.Internal.Data.Fold
, Streamly.Internal.Data.Fold.Chunked
@ -341,13 +331,11 @@ library
, Streamly.Internal.Data.Pipe
-- streamly-transformers (non-base)
, Streamly.Internal.Data.Stream.StreamD.Transformer
, Streamly.Internal.Data.Stream.StreamK.Transformer
-- streamly-containers (non-base)
, Streamly.Internal.Data.Stream.StreamD.Container
, Streamly.Internal.Data.Fold.Container
, Streamly.Internal.Data.Fold.Container
, Streamly.Internal.Data.Stream.Chunked
-- streamly-core-data-arrays
@ -420,6 +408,20 @@ library
, Streamly.Unicode.Parser
, Streamly.Unicode.Stream
, Streamly.Unicode.String
other-modules:
Streamly.Internal.Data.Stream.StreamD.Container
, Streamly.Internal.Data.Stream.StreamD.Eliminate
, Streamly.Internal.Data.Stream.StreamD.Exception
, Streamly.Internal.Data.Stream.StreamD.Generate
, Streamly.Internal.Data.Stream.StreamD.Lift
, Streamly.Internal.Data.Stream.StreamD.Nesting
, Streamly.Internal.Data.Stream.StreamD.Step
, Streamly.Internal.Data.Stream.StreamD.Top
, Streamly.Internal.Data.Stream.StreamD.Transform
, Streamly.Internal.Data.Stream.StreamD.Transformer
, Streamly.Internal.Data.Stream.StreamD.Type
, Streamly.Internal.Data.Unfold.Enumeration
if flag(dev)
exposed-modules:

2
src/Streamly/Internal/Data/Fold/Concurrent/Channel/Type.hs
View File

@ -34,7 +34,7 @@ import Streamly.Internal.Data.Stream.Channel.Dispatcher (dumpSVarStats)
import Streamly.Internal.Data.Stream.Channel.Worker (sendWithDoorBell)
import qualified Streamly.Internal.Data.Fold as Fold
import qualified Streamly.Internal.Data.Stream.StreamD.Type as D
import qualified Streamly.Internal.Data.Stream as D
import Streamly.Internal.Data.Stream.Channel.Types

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

@ -59,7 +59,7 @@ import Streamly.Internal.Data.Stream.StreamK.Type (Stream)
import qualified Streamly.Internal.Data.Stream.StreamK.Type as K
(foldStreamShared, cons, mkStream, foldStream, fromEffect
, nil, concatMapWith, fromPure, bindWith)
import qualified Streamly.Internal.Data.Stream.StreamD.Type as D
import qualified Streamly.Internal.Data.Stream as D
(mapM, fromStreamK, toStreamK)
import qualified Streamly.Internal.Data.Stream.Serial as Stream (toStreamK)

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

@ -70,7 +70,7 @@ import Streamly.Internal.Data.Stream.SVar.Generate (fromSVar, fromSVarD)
import qualified Streamly.Internal.Data.Stream.StreamK.Type as K
(foldStreamShared, mkStream, foldStream, fromEffect
, nil, concatMapWith, fromPure, bindWith)
import qualified Streamly.Internal.Data.Stream.StreamD.Type as D
import qualified Streamly.Internal.Data.Stream as D
(Stream(..), Step(..), mapM, toStreamK, fromStreamK)
import qualified Streamly.Internal.Data.Stream.Serial as Stream (toStreamK)

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

@ -110,7 +110,7 @@ import Streamly.Internal.Data.Stream.Channel.Types
, concatMapDivK
)
import Streamly.Internal.Data.Stream.Channel.Worker (sendWithDoorBell)
import Streamly.Internal.Data.Stream.StreamD.Type (Stream)
import Streamly.Internal.Data.Stream (Stream)
import Streamly.Internal.Data.Stream (Step(..))
import qualified Streamly.Internal.Data.IORef.Unboxed as Unboxed

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

@ -34,12 +34,12 @@ import Data.IORef (newIORef, readIORef, mkWeakIORef, writeIORef)
import Data.Maybe (isNothing)
import Streamly.Internal.Control.Concurrent
(MonadAsync, MonadRunInIO, askRunInIO)
import Streamly.Internal.Data.Stream.StreamD.Type (Stream)
import Streamly.Internal.Data.Stream (Stream)
import Streamly.Internal.Data.Time.Clock (Clock(Monotonic), getTime)
import System.Mem (performMajorGC)
import qualified Streamly.Internal.Data.Stream as Stream
import qualified Streamly.Internal.Data.Stream.StreamD.Type as D
import qualified Streamly.Internal.Data.Stream as D
import qualified Streamly.Internal.Data.Stream.StreamK.Type as K
import Streamly.Internal.Data.Stream.Concurrent.Channel.Dispatcher

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

@ -35,7 +35,7 @@ import Data.Map.Strict (Map)
import GHC.Exts (inline)
import Streamly.Internal.Control.Concurrent
(MonadRunInIO, MonadAsync, withRunInIO)
import Streamly.Internal.Data.Stream.StreamD.Type (Stream)
import Streamly.Internal.Data.Stream (Stream)
import Streamly.Internal.Data.IOFinalizer.Lifted
(newIOFinalizer, runIOFinalizer, clearingIOFinalizer)
import Streamly.Internal.Data.Stream (Step(..))

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

@ -32,7 +32,7 @@ import Streamly.Internal.Control.Concurrent (MonadRunInIO, MonadAsync)
import Streamly.Internal.Data.Stream.IsStream.Type
(IsStream(..), fromStreamD, toStreamD)
import qualified Streamly.Internal.Data.Stream.StreamD.Exception as D
import qualified Streamly.Internal.Data.Stream as D
( before
, afterUnsafe
, onException

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

@ -119,7 +119,7 @@ import qualified Streamly.Internal.Data.Stream.Ahead as Ahead
import qualified Streamly.Internal.Data.Stream.Async as Async
import qualified Streamly.Internal.Data.Stream.Parallel as Parallel
import qualified Streamly.Internal.Data.Stream.Serial as Serial
import qualified Streamly.Internal.Data.Stream.StreamD.Type as D
import qualified Streamly.Internal.Data.Stream as D
(Stream(..), toStreamK, fromStreamK
, drain, eqBy, cmpBy, fromList, toList, foldrMx, foldlMx'
, foldlx', foldl', fold)

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

@ -66,13 +66,13 @@ import Data.Maybe (fromJust)
import Streamly.Data.Fold (Fold)
import Streamly.Internal.Control.Concurrent (MonadAsync)
import Streamly.Internal.Data.Stream.StreamD.Type (Step(..))
import Streamly.Internal.Data.Stream (Step(..))
import qualified Data.Set as Set
import qualified Streamly.Internal.Data.Stream.StreamK.Type as K
(StreamK, foldStreamShared, mkStream, foldStream, fromEffect
, nil, concatMapWith, fromPure, bindWith)
import qualified Streamly.Internal.Data.Stream.StreamD.Type as D
import qualified Streamly.Internal.Data.Stream as D
(Stream(..), mapM, toStreamK, fromStreamK)
import qualified Streamly.Internal.Data.Stream.SVar.Generate as SVar
import qualified Streamly.Internal.Data.Stream.SVar.Eliminate as SVar

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

@ -40,7 +40,7 @@ import Streamly.Internal.Data.Fold.Type (Fold(..))
import Streamly.Internal.Data.Stream.Serial (SerialT)
import Streamly.Internal.Data.Time.Clock (Clock(Monotonic), getTime)
import qualified Streamly.Internal.Data.Stream.StreamD.Type as D
import qualified Streamly.Internal.Data.Stream as D
(Stream(..), Step(..), fold)
import qualified Streamly.Internal.Data.Stream.StreamK.Type as K
(Stream, mkStream, foldStream, foldStreamShared, nilM)

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

@ -43,7 +43,7 @@ import Streamly.Internal.Data.Stream.Serial (SerialT)
import Streamly.Internal.Data.Time.Clock (Clock(Monotonic), getTime)
import System.Mem (performMajorGC)
import qualified Streamly.Internal.Data.Stream.StreamD.Type as D
import qualified Streamly.Internal.Data.Stream as D
(Stream(..), Step(..))
import qualified Streamly.Internal.Data.Stream.StreamK.Type as K
(Stream, foldStreamShared, mkStream, foldStream)

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

@ -73,9 +73,7 @@ import Streamly.Internal.Data.Maybe.Strict (Maybe'(..), toMaybe)
import Streamly.Internal.Data.Stream.StreamK.Type (Stream)
import qualified Streamly.Internal.Data.Stream.Common as P
import qualified Streamly.Internal.Data.Stream.StreamD.Generate as D
import qualified Streamly.Internal.Data.Stream.StreamD.Transform as D
import qualified Streamly.Internal.Data.Stream.StreamD.Type as D
import qualified Streamly.Internal.Data.Stream as D
import qualified Streamly.Internal.Data.Stream.StreamK.Type as K
import Prelude hiding (map, mapM, repeat, filter)

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

@ -62,7 +62,7 @@ import Data.Proxy (Proxy(..))
import Streamly.Data.Fold (Fold)
import Streamly.Internal.Data.Fold.Type (Fold (..))
import Streamly.Internal.Data.IsMap (IsMap(..))
import Streamly.Internal.Data.Stream.StreamD.Type (Stream)
import Streamly.Internal.Data.Stream (Stream)
import Streamly.Internal.Data.Time.Units
( AbsTime
, MilliSecond64(..)

2
src/Streamly/Internal/Data/Unfold/Exception.hs
View File

@ -25,7 +25,7 @@ import Streamly.Internal.Control.Concurrent
(MonadRunInIO, MonadAsync, withRunInIO)
import Streamly.Internal.Data.IOFinalizer.Lifted
(newIOFinalizer, runIOFinalizer, clearingIOFinalizer)
import Streamly.Internal.Data.Stream.StreamD.Type (Step(..))
import Streamly.Internal.Data.Stream (Step(..))
import qualified Control.Monad.Catch as MC

2
src/Streamly/Internal/Data/Unfold/SVar.hs
View File

@ -21,7 +21,7 @@ import Control.Monad.IO.Class (MonadIO(..))
import Data.IORef (newIORef, readIORef, mkWeakIORef, writeIORef)
import Data.Maybe (isNothing)
import Streamly.Internal.Control.Concurrent (MonadAsync)
import Streamly.Internal.Data.Stream.StreamD.Type (Step(..))
import Streamly.Internal.Data.Stream (Step(..))
import Streamly.Internal.Data.Time.Clock (Clock(Monotonic), getTime)
import Streamly.Internal.Data.SVar (printSVar, cleanupSVar, sendStopToProducer)
import Streamly.Internal.Data.Unfold.Type (Unfold(..))

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

@ -131,7 +131,7 @@ import qualified GHC.IO.Device as RawIO
import Streamly.Internal.Data.Array.Type
(Array(..), byteLength, unsafeFreeze, asPtrUnsafe)
import Streamly.Internal.System.IO (defaultChunkSize)
import Streamly.Internal.Data.Stream.StreamD.Type (Stream)
import Streamly.Internal.Data.Stream (Stream)
#if !defined(mingw32_HOST_OS)
{-
import Streamly.Internal.Data.Stream.IsStream.Type (toStreamD)
@ -149,7 +149,7 @@ import qualified Streamly.Internal.Data.MutArray as MArray
(MutArray(..), asPtrUnsafe)
import qualified Streamly.Internal.Data.Stream.Chunked as AS
import qualified Streamly.Internal.Data.Stream as S
import qualified Streamly.Internal.Data.Stream.StreamD.Type as D
import qualified Streamly.Internal.Data.Stream as D
(Stream(..), Step(..))
import qualified Streamly.Internal.Data.Stream.StreamK.Type as K (mkStream)

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

@ -89,7 +89,7 @@ import qualified Network.Socket as Net
import Streamly.Internal.Data.Array.Type (Array(..))
import Streamly.Internal.Data.Stream.Chunked (lpackArraysChunksOf)
import Streamly.Internal.Data.Fold (Fold)
import Streamly.Internal.Data.Stream.StreamD.Type (Stream)
import Streamly.Internal.Data.Stream (Stream)
import Streamly.Internal.Data.Unfold.Type (Unfold(..))
-- import Streamly.String (encodeUtf8, decodeUtf8, foldLines)
import Streamly.Internal.System.IO (defaultChunkSize)
@ -101,7 +101,7 @@ import qualified Streamly.Internal.Data.Array.Type as A
import qualified Streamly.Internal.Data.MutArray as MArray
(MutArray(..), asPtrUnsafe, pinnedNewBytes)
import qualified Streamly.Internal.Data.Stream as S
import qualified Streamly.Internal.Data.Stream.StreamD.Type as D
import qualified Streamly.Internal.Data.Stream as D
(Stream(..), Step(..))
import qualified Streamly.Data.Unfold as UF
import qualified Streamly.Internal.Data.Unfold as UF (first, map)

28
streamly.cabal
View File

@ -410,9 +410,6 @@ library
, Streamly.Prelude
-- Deprecated Internal modules
, Streamly.Internal.Data.SVar.Worker
, Streamly.Internal.Data.SVar.Dispatch
, Streamly.Internal.Data.SVar.Pull
, Streamly.Internal.Data.SVar
, Streamly.Internal.Data.Unfold.SVar
@ -428,19 +425,10 @@ library
, Streamly.Internal.Data.Stream.Ahead
, Streamly.Internal.Data.Stream.ZipAsync
, Streamly.Internal.Data.Stream.IsStream.Type
, Streamly.Internal.Data.Stream.IsStream
, Streamly.Internal.Data.Stream.IsStream.Combinators
, Streamly.Internal.Data.Stream.IsStream.Common
, Streamly.Internal.Data.Stream.IsStream.Enumeration
, Streamly.Internal.Data.Stream.IsStream.Generate
, Streamly.Internal.Data.Stream.IsStream.Eliminate
, Streamly.Internal.Data.Stream.IsStream.Transform
, Streamly.Internal.Data.Stream.IsStream.Expand
, Streamly.Internal.Data.Stream.IsStream.Reduce
, Streamly.Internal.Data.Stream.IsStream.Exception
, Streamly.Internal.Data.Stream.IsStream.Lift
, Streamly.Internal.Data.Stream.IsStream.Top
, Streamly.Internal.Data.Stream.IsStream
if !impl(ghcjs) && flag(dev)
exposed-modules:
@ -473,6 +461,20 @@ library
, Streamly.Data.Stream.Concurrent
, Streamly.Data.Stream.Time
, Streamly.Internal.Data.Stream.IsStream.Type
, Streamly.Internal.Data.Stream.IsStream.Generate
, Streamly.Internal.Data.Stream.IsStream.Eliminate
, Streamly.Internal.Data.Stream.IsStream.Transform
, Streamly.Internal.Data.Stream.IsStream.Expand
, Streamly.Internal.Data.Stream.IsStream.Reduce
, Streamly.Internal.Data.Stream.IsStream.Exception
, Streamly.Internal.Data.Stream.IsStream.Lift
, Streamly.Internal.Data.Stream.IsStream.Top
, Streamly.Internal.Data.SVar.Worker
, Streamly.Internal.Data.SVar.Dispatch
, Streamly.Internal.Data.SVar.Pull
build-depends:
-- Core libraries shipped with ghc, the min and max
-- constraints of these libraries should match with

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

@ -14,7 +14,7 @@ import Test.QuickCheck
)
import Test.QuickCheck.Monadic (monadicIO, assert, run)
import qualified Streamly.Prelude as S
import qualified Streamly.Internal.Data.Stream.IsStream.Top as Top
import qualified Streamly.Internal.Data.Stream.IsStream as Top
import Prelude hiding
(maximum, minimum, elem, notElem, null, product, sum, head, last, take)