Mv Streams/Combinators.hs to Internal/Data/Stream

src/Streamly.hs

@@ -226,7 +226,7 @@ import Data.Semigroup (Semigroup(..))
 import Streamly.Internal.Data.SVar (MonadAsync, Rate(..))
 import Streamly.Internal.Data.Stream.Ahead
 import Streamly.Internal.Data.Stream.Async
-import Streamly.Streams.Combinators
+import Streamly.Internal.Data.Stream.Combinators
 import Streamly.Streams.Parallel
 import Streamly.Streams.Serial
 import Streamly.Internal.Data.Stream.StreamK hiding (serial)

src/Streamly/Internal/Data/Stream/Combinators.hs

@@ -3,7 +3,7 @@
 #include "inline.hs"
 
 -- |
--- Module      : Streamly.Streams.Combinators
+-- Module      : Streamly.Internal.Data.Stream.Combinators
 -- Copyright   : (c) 2017 Harendra Kumar
 --
 -- License     : BSD3
@@ -12,7 +12,7 @@
 -- Portability : GHC
 --
 --
-module Streamly.Streams.Combinators
+module Streamly.Internal.Data.Stream.Combinators
     ( maxThreads
     , maxBuffer
     , maxYields

src/Streamly/Internal/Prelude.hs

@@ -448,7 +448,7 @@ import Streamly.Internal.Memory.Array.Types (Array, writeNUnsafe)
 -- import Streamly.Memory.Ring (Ring)
 import Streamly.Internal.Data.SVar (MonadAsync, State, defState, adaptState)
 import Streamly.Internal.Data.Stream.Async (mkAsync')
-import Streamly.Streams.Combinators (inspectMode, maxYields)
+import Streamly.Internal.Data.Stream.Combinators (inspectMode, maxYields)
 import Streamly.Streams.Prelude
        (fromStreamS, toStreamS, foldWith, foldMapWith, forEachWith)
 import Streamly.Internal.Data.Stream.StreamD (fromStreamD, toStreamD)

streamly.cabal

@@ -293,7 +293,7 @@ library
                      , Streamly.Streams.Parallel
                      , Streamly.Internal.Data.Stream.Ahead
                      , Streamly.Streams.Zip
-                     , Streamly.Streams.Combinators
+                     , Streamly.Internal.Data.Stream.Combinators
 
                      , Streamly.FileSystem.IOVec
                      , Streamly.FileSystem.FDIO