Revert "Move the Parallel module under IsStream"

This reverts commit e718389b2c.

benchmark/Streamly/Benchmark/Data/Stream/Transform.hs

@@ -35,7 +35,7 @@ import qualified Streamly.Internal.Data.Unfold as Unfold
 import qualified Streamly.Internal.Data.Stream.IsStream as Stream
 import Streamly.Internal.Data.Time.Units
 #else
-import qualified Streamly.Internal.Data.Stream.IsStream.Parallel as Stream
+import qualified Streamly.Internal.Data.Stream.Parallel as Stream
 import qualified Streamly.Internal.Data.Stream as Stream
 #endif
 

src/Streamly/Internal/Data/Stream/IsStream/Common.hs

@@ -84,7 +84,7 @@ import qualified Streamly.Data.Stream as Stream (fold, foldBreak)
 import qualified Streamly.Internal.Data.Array.Unboxed.Type as A
 import qualified Streamly.Internal.Data.Stream.IsStream.Async as Async
 import qualified Streamly.Internal.Data.Stream.IsStream.Type as IsStream
-import qualified Streamly.Internal.Data.Stream.IsStream.Parallel as Par
+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

src/Streamly/Internal/Data/Stream/IsStream/Expand.hs

@@ -174,7 +174,7 @@ import Streamly.Internal.Data.Stream.IsStream.Type
 import Streamly.Data.Unfold (Unfold)
 
 import qualified Streamly.Internal.Data.Stream.IsStream.Type as IsStream
-import qualified Streamly.Internal.Data.Stream.IsStream.Parallel as Par
+import qualified Streamly.Internal.Data.Stream.Parallel as Par
 import qualified Streamly.Internal.Data.Stream.WSerial as WSerial
 import qualified Streamly.Internal.Data.Stream.StreamD as D
     (append, interleave, interleaveSuffix, interleaveInfix, interleaveMin

src/Streamly/Internal/Data/Stream/IsStream/Generate.hs

@@ -109,7 +109,7 @@ import Streamly.Internal.Data.Unboxed (Unboxed)
 import qualified Streamly.Internal.Data.IORef.Unboxed as Unboxed
     (toStreamD, IORef)
 import qualified Streamly.Internal.Data.Stream.IsStream.Type as IsStream
-import qualified Streamly.Internal.Data.Stream.IsStream.Parallel as Par
+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
     (unfold, unfoldr, toStreamK, unfoldr, repeat, replicate, replicateM

src/Streamly/Internal/Data/Stream/IsStream/Transform.hs

@@ -251,7 +251,7 @@ import Streamly.Internal.Data.SVar (Rate(..))
 import Streamly.Internal.Data.Time.Units (AbsTime, RelTime64)
 
 import qualified Streamly.Data.Fold as FL
-import qualified Streamly.Internal.Data.Stream.IsStream.Parallel as Par
+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
     (transform, foldrT, tap, tapOffsetEvery, pollCounts, mapM, scanOnce

src/Streamly/Internal/Data/Stream/IsStream/Type.hs

@@ -106,8 +106,7 @@ import Streamly.Internal.Data.Stream.WSerial (WSerialT(..), WSerial)
 import Streamly.Internal.Data.Stream.IsStream.Async
     (AsyncT(..), Async, WAsyncT(..), WAsync)
 import Streamly.Internal.Data.Stream.Ahead (AheadT(..), Ahead)
-import Streamly.Internal.Data.Stream.IsStream.Parallel
-    (ParallelT(..), Parallel)
+import Streamly.Internal.Data.Stream.Parallel (ParallelT(..), Parallel)
 import Streamly.Internal.Data.Stream.Zip (ZipSerialM, ZipSerial)
 import Streamly.Internal.Data.Stream.ZipAsync (ZipAsyncM(..), ZipAsync)
 import Streamly.Internal.Data.SVar.Type (State, adaptState)
@@ -115,7 +114,7 @@ import Streamly.Internal.Data.SVar.Type (State, adaptState)
 import qualified Prelude
 import qualified Streamly.Internal.Data.Stream.Ahead as Ahead
 import qualified Streamly.Internal.Data.Stream.IsStream.Async as Async
-import qualified Streamly.Internal.Data.Stream.IsStream.Parallel as Parallel
+import qualified Streamly.Internal.Data.Stream.Parallel as Parallel
 import qualified Streamly.Internal.Data.Stream.Serial as Serial
 import qualified Streamly.Internal.Data.Stream.WSerial as WSerial
 import qualified Streamly.Internal.Data.Stream.StreamD.Type as D

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

@@ -1,7 +1,7 @@
 {-# LANGUAGE UndecidableInstances #-}
 
 -- |
--- Module      : Streamly.Internal.Data.Stream.IsStream.Parallel
+-- Module      : Streamly.Internal.Data.Stream.Parallel
 -- Copyright   : (c) 2017 Composewell Technologies
 --
 -- License     : BSD3
@@ -20,7 +20,7 @@
 --      return n                    -- IO Int
 -- :}
 --
-module Streamly.Internal.Data.Stream.IsStream.Parallel
+module Streamly.Internal.Data.Stream.Parallel
     (
     -- * Parallel Stream Type
       ParallelT(..)
@@ -542,7 +542,7 @@ parallelFst m1 m2 =
 -- seconds.
 --
 -- >>> import qualified Streamly.Data.Fold as Fold
--- >>> import qualified Streamly.Internal.Data.Stream.IsStream.Parallel as Parallel
+-- >>> import qualified Streamly.Internal.Data.Stream.Parallel as Parallel
 -- >>> Stream.fold Fold.drain $ Parallel.interjectSuffix 1.05 (putChar ',') $ Stream.mapM (\x -> threadDelay 1000000 >> putChar x) $ Stream.fromList "hello"
 -- h,e,l,l,o
 --

streamly.cabal

@@ -345,6 +345,7 @@ library
 
                      , Streamly.Internal.Data.Stream.Serial
                      , Streamly.Internal.Data.Stream.WSerial
+                     , Streamly.Internal.Data.Stream.Parallel
                      , Streamly.Internal.Data.Stream.Channel.Types
                      , Streamly.Internal.Data.Stream.Channel.Dispatcher
                      , Streamly.Internal.Data.Stream.Channel.Worker
@@ -373,7 +374,6 @@ library
                      , Streamly.Internal.Data.Stream.IsStream.Lift
                      , Streamly.Internal.Data.Stream.IsStream.Top
                      , Streamly.Internal.Data.Stream.IsStream.Async
-                     , Streamly.Internal.Data.Stream.IsStream.Parallel
                      , Streamly.Internal.Data.Stream.IsStream
 
                      -- streamly-unicode