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

Move StreamD.Type to Internal

Browse Source
This commit is contained in:
adithyaov 2019-11-07 13:59:51 +05:30
parent ffcfcacc72
commit c88755f4de
11 changed files with 18 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/Streamly/Benchmark/FileIO/Array.hs
View File

@ -55,7 +55,7 @@ import qualified Streamly.Internal.Data.Unfold as IUF
#ifdef INSPECTION
import Foreign.Storable (Storable)
import Streamly.Streams.StreamD.Type (Step(..))
import Streamly.Internal.Data.Stream.StreamD.Type (Step(..))
import Test.Inspection
#endif

2
src/Streamly/Benchmark/FileIO/Stream.hs
View File

@ -86,7 +86,7 @@ import qualified Streamly.Streams.StreamD as D
#ifdef INSPECTION
import Foreign.Storable (Storable)
import Streamly.Streams.StreamD.Type (Step(..), GroupState)
import Streamly.Internal.Data.Stream.StreamD.Type (Step(..), GroupState)
import Test.Inspection
#endif

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

@ -143,7 +143,7 @@ import Streamly.Streams.StreamK.Type (IsStream, mkStream)
#if !defined(mingw32_HOST_OS)
import Streamly.Internal.Memory.Array.Types (groupIOVecsOf)
import Streamly.Streams.StreamD (toStreamD)
import Streamly.Streams.StreamD.Type (fromStreamD)
import Streamly.Internal.Data.Stream.StreamD.Type (fromStreamD)
import qualified Streamly.FileSystem.FDIO as RawIO hiding (write)
#endif
-- import Streamly.Data.Fold (Fold)
@ -152,7 +152,7 @@ import qualified Streamly.FileSystem.FDIO as RawIO hiding (write)
import qualified Streamly.Memory.Array as A
import qualified Streamly.Internal.Memory.ArrayStream as AS
import qualified Streamly.Prelude as S
import qualified Streamly.Streams.StreamD.Type as D
import qualified Streamly.Internal.Data.Stream.StreamD.Type as D
-------------------------------------------------------------------------------
-- References

8
src/Streamly/Streams/StreamD/Type.hs → src/Streamly/Internal/Data/Stream/StreamD/Type.hs
View File

@ -9,10 +9,10 @@
{-# LANGUAGE ViewPatterns #-}
{-# LANGUAGE RankNTypes #-}
#include "../inline.hs"
#include "inline.hs"
-- |
-- Module : Streamly.Streams.StreamD.Type
-- Module : Streamly.Internal.Data.Stream.StreamD.Type
-- Copyright : (c) 2018 Harendra Kumar
-- Copyright : (c) Roman Leshchinskiy 2008-2010
--
@ -21,7 +21,7 @@
-- Stability : experimental
-- Portability : GHC
module Streamly.Streams.StreamD.Type
module Streamly.Internal.Data.Stream.StreamD.Type
(
-- * The stream type
Step (..)
@ -519,7 +519,7 @@ groupsOf n (Fold fstep initial extract) (Stream step state) =
-- implications.
when (n <= 0) $
-- XXX we can pass the module string from the higher level API
error $ "Streamly.Streams.StreamD.Type.groupsOf: the size of "
error $ "Streamly.Internal.Data.Stream.StreamD.Type.groupsOf: the size of "
++ "groups [" ++ show n ++ "] must be a natural number"
-- fs = fold state
fs <- initial

4
src/Streamly/Internal/Data/Unfold.hs
View File

@ -123,9 +123,9 @@ import Data.Void (Void)
import GHC.Types (SPEC(..))
import Prelude hiding (concat, map, takeWhile, take, filter, const)
import Streamly.Streams.StreamD.Type (Stream(..), Step(..))
import Streamly.Internal.Data.Stream.StreamD.Type (Stream(..), Step(..))
#if __GLASGOW_HASKELL__ < 800
import Streamly.Streams.StreamD.Type (pattern Stream)
import Streamly.Internal.Data.Stream.StreamD.Type (pattern Stream)
#endif
import Streamly.Internal.Data.Unfold.Types (Unfold(..))
import Streamly.Internal.Data.Fold.Types (Fold(..))

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

@ -16,7 +16,7 @@ module Streamly.Internal.Data.Unfold.Types
)
where
import Streamly.Streams.StreamD.Type (Step(..))
import Streamly.Internal.Data.Stream.StreamD.Type (Step(..))
------------------------------------------------------------------------------
-- Monadic Unfolds

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

@ -123,7 +123,7 @@ import qualified Streamly.Internal.Data.Unfold as UF
import qualified Streamly.Internal.Memory.ArrayStream as AS
import qualified Streamly.Internal.Prelude as S
import qualified Streamly.Memory.Array as A
import qualified Streamly.Streams.StreamD.Type as D
import qualified Streamly.Internal.Data.Stream.StreamD.Type as D
-------------------------------------------------------------------------------
-- References

2
src/Streamly/Internal/Memory/Array/Types.hs
View File

@ -120,7 +120,7 @@ import Streamly.FileSystem.FDIO (IOVec(..))
#endif
import qualified Streamly.Memory.Malloc as Malloc
import qualified Streamly.Streams.StreamD.Type as D
import qualified Streamly.Internal.Data.Stream.StreamD.Type as D
import qualified Streamly.Streams.StreamK as K
import qualified GHC.Exts as Exts

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

@ -102,7 +102,7 @@ import qualified Streamly.Memory.Array as A
import qualified Streamly.Internal.Memory.ArrayStream as AS
import qualified Streamly.Internal.Memory.Array.Types as A
import qualified Streamly.Prelude as S
import qualified Streamly.Streams.StreamD.Type as D
import qualified Streamly.Internal.Data.Stream.StreamD.Type as D
-- | @'useSocketM' socket act@ runs the monadic computation @act@ passing the
-- socket handle to it. The handle will be closed on exit from 'useSocketM',

2
src/Streamly/Streams/StreamD.hs
View File

@ -330,7 +330,7 @@ import Streamly.Internal.Data.SVar (MonadAsync, defState, adaptState)
import Streamly.Internal.Data.Unfold.Types (Unfold(..))
import Streamly.Internal.Data.Strict (Tuple'(..))
import Streamly.Streams.StreamD.Type
import Streamly.Internal.Data.Stream.StreamD.Type
import qualified Streamly.Internal.Data.Pipe.Types as Pipe
import qualified Streamly.Internal.Memory.Array.Types as A

6
streamly.cabal
View File

@ -270,7 +270,6 @@ library
, Streamly.Streams.StreamK
, Streamly.Streams.StreamDK.Type
, Streamly.Streams.StreamDK
, Streamly.Streams.StreamD.Type
, Streamly.Streams.StreamD
, Streamly.Streams.Enumeration
, Streamly.Streams.Prelude
@ -306,6 +305,7 @@ library
, Streamly.Internal.Data.Time
, Streamly.Internal.Data.Time.Units
, Streamly.Internal.Data.Time.Clock
, Streamly.Internal.Data.Stream.StreamD.Type
, Streamly.Internal.Data.SVar
, Streamly.Internal.Memory.Array.Types
, Streamly.Internal.Memory.Array
@ -670,6 +670,7 @@ benchmark base
hs-source-dirs: benchmark, src
main-is: BaseStreams.hs
other-modules: Streamly.Internal.Data.Atomics
, Streamly.Internal.Data.Stream.StreamD.Type
, Streamly.Internal.Data.SVar
, Streamly.Internal.Data.Time.Units
, Streamly.Internal.Data.Time.Clock
@ -677,7 +678,6 @@ benchmark base
, Streamly.Streams.StreamDK
, Streamly.Streams.StreamK.Type
, Streamly.Streams.StreamK
, Streamly.Streams.StreamD.Type
, Streamly.Streams.StreamD
, Streamly.Streams.Prelude
, Streamly.FileSystem.IOVec
@ -725,12 +725,12 @@ executable nano-bench
c-sources: src/Streamly/Internal/Data/Time/Darwin.c
main-is: NanoBenchmarks.hs
other-modules: Streamly.Internal.Data.Atomics
, Streamly.Internal.Data.Stream.StreamD.Type
, Streamly.Internal.Data.SVar
, Streamly.Internal.Data.Time.Units
, Streamly.Internal.Data.Time.Clock
, Streamly.Streams.StreamK.Type
, Streamly.Streams.StreamK
, Streamly.Streams.StreamD.Type
, Streamly.FileSystem.IOVec
, Streamly.Streams.StreamD
if flag(dev)