git.iko.soy/streamly
on master help sign in
Move the Parallel module under IsStream
e718389Harendra Kumar
benchmark/Streamly/Benchmark/Data/Stream/Transform.hs+1−1
compare with master
unifiedsplit
@@ -35,7 +35,7 @@ import qualified Streamly.Internal.Data.Unfold as Unfold
35import qualified Streamly.Internal.Data.Stream.IsStream as Stream
35import qualified Streamly.Internal.Data.Stream.IsStream as Stream
36import Streamly.Internal.Data.Time.Units
36import Streamly.Internal.Data.Time.Units
37#else
37#else
38−import qualified Streamly.Internal.Data.Stream.Parallel as Stream
38+import qualified Streamly.Internal.Data.Stream.IsStream.Parallel as Stream
39import qualified Streamly.Internal.Data.Stream as Stream
39import qualified Streamly.Internal.Data.Stream as Stream
40#endif
40#endif
41
41
src/Streamly/Internal/Data/Stream/IsStream/Common.hs+1−1
@@ -84,7 +84,7 @@ import qualified Streamly.Data.Stream as Stream (fold, foldBreak)
84import qualified Streamly.Internal.Data.Array.Unboxed.Type as A
84import qualified Streamly.Internal.Data.Array.Unboxed.Type as A
85import qualified Streamly.Internal.Data.Stream.IsStream.Async as Async
85import qualified Streamly.Internal.Data.Stream.IsStream.Async as Async
86import qualified Streamly.Internal.Data.Stream.IsStream.Type as IsStream
86import qualified Streamly.Internal.Data.Stream.IsStream.Type as IsStream
87−import qualified Streamly.Internal.Data.Stream.Parallel as Par
87+import qualified Streamly.Internal.Data.Stream.IsStream.Parallel as Par
88import qualified Streamly.Internal.Data.Stream.StreamK.Type as K
88import qualified Streamly.Internal.Data.Stream.StreamK.Type as K
89 (fromPure, fromEffect, repeatMWith, reverse)
89 (fromPure, fromEffect, repeatMWith, reverse)
90import qualified Streamly.Internal.Data.Stream.StreamD as D
90import qualified Streamly.Internal.Data.Stream.StreamD as D
src/Streamly/Internal/Data/Stream/IsStream/Expand.hs+1−1
@@ -174,7 +174,7 @@ import Streamly.Internal.Data.Stream.IsStream.Type
174import Streamly.Data.Unfold (Unfold)
174import Streamly.Data.Unfold (Unfold)
175
175
176import qualified Streamly.Internal.Data.Stream.IsStream.Type as IsStream
176import qualified Streamly.Internal.Data.Stream.IsStream.Type as IsStream
177−import qualified Streamly.Internal.Data.Stream.Parallel as Par
177+import qualified Streamly.Internal.Data.Stream.IsStream.Parallel as Par
178import qualified Streamly.Internal.Data.Stream.WSerial as WSerial
178import qualified Streamly.Internal.Data.Stream.WSerial as WSerial
179import qualified Streamly.Internal.Data.Stream.StreamD as D
179import qualified Streamly.Internal.Data.Stream.StreamD as D
180 (append, interleave, interleaveSuffix, interleaveInfix, interleaveMin
180 (append, interleave, interleaveSuffix, interleaveInfix, interleaveMin
src/Streamly/Internal/Data/Stream/IsStream/Generate.hs+1−1
@@ -109,7 +109,7 @@ import Streamly.Internal.Data.Unboxed (Unboxed)
109import qualified Streamly.Internal.Data.IORef.Unboxed as Unboxed
109import qualified Streamly.Internal.Data.IORef.Unboxed as Unboxed
110 (toStreamD, IORef)
110 (toStreamD, IORef)
111import qualified Streamly.Internal.Data.Stream.IsStream.Type as IsStream
111import qualified Streamly.Internal.Data.Stream.IsStream.Type as IsStream
112−import qualified Streamly.Internal.Data.Stream.Parallel as Par
112+import qualified Streamly.Internal.Data.Stream.IsStream.Parallel as Par
113import qualified Streamly.Internal.Data.Stream.Serial as Serial
113import qualified Streamly.Internal.Data.Stream.Serial as Serial
114import qualified Streamly.Internal.Data.Stream.StreamD as D
114import qualified Streamly.Internal.Data.Stream.StreamD as D
115 (unfold, unfoldr, toStreamK, unfoldr, repeat, replicate, replicateM
115 (unfold, unfoldr, toStreamK, unfoldr, repeat, replicate, replicateM
src/Streamly/Internal/Data/Stream/Parallel.hs → src/Streamly/Internal/Data/Stream/IsStream/Parallel.hsrenamed+3−3
@@ -1,7 +1,7 @@
1{-# LANGUAGE UndecidableInstances #-}
1{-# LANGUAGE UndecidableInstances #-}
2
2
3-- |
3-- |
4−-- Module : Streamly.Internal.Data.Stream.Parallel
4+-- Module : Streamly.Internal.Data.Stream.IsStream.Parallel
5-- Copyright : (c) 2017 Composewell Technologies
5-- Copyright : (c) 2017 Composewell Technologies
6--
6--
7-- License : BSD3
7-- License : BSD3
@@ -20,7 +20,7 @@
20-- return n -- IO Int
20-- return n -- IO Int
21-- :}
21-- :}
22--
22--
23−module Streamly.Internal.Data.Stream.Parallel
23+module Streamly.Internal.Data.Stream.IsStream.Parallel
24 (
24 (
25 -- * Parallel Stream Type
25 -- * Parallel Stream Type
26 ParallelT(..)
26 ParallelT(..)
@@ -545,7 +545,7 @@ parallelFst m1 m2 =
545-- seconds.
545-- seconds.
546--
546--
547-- >>> import qualified Streamly.Data.Fold as Fold
547-- >>> import qualified Streamly.Data.Fold as Fold
548−-- >>> import qualified Streamly.Internal.Data.Stream.Parallel as Parallel
548+-- >>> import qualified Streamly.Internal.Data.Stream.IsStream.Parallel as Parallel
549-- >>> Stream.fold Fold.drain $ Parallel.interjectSuffix 1.05 (putChar ',') $ Stream.mapM (\x -> threadDelay 1000000 >> putChar x) $ Stream.fromList "hello"
549-- >>> Stream.fold Fold.drain $ Parallel.interjectSuffix 1.05 (putChar ',') $ Stream.mapM (\x -> threadDelay 1000000 >> putChar x) $ Stream.fromList "hello"
550-- h,e,l,l,o
550-- h,e,l,l,o
551--
551--
src/Streamly/Internal/Data/Stream/IsStream/Transform.hs+1−1
@@ -251,7 +251,7 @@ import Streamly.Internal.Data.SVar (Rate(..))
251import Streamly.Internal.Data.Time.Units (AbsTime, RelTime64)
251import Streamly.Internal.Data.Time.Units (AbsTime, RelTime64)
252
252
253import qualified Streamly.Data.Fold as FL
253import qualified Streamly.Data.Fold as FL
254−import qualified Streamly.Internal.Data.Stream.Parallel as Par
254+import qualified Streamly.Internal.Data.Stream.IsStream.Parallel as Par
255import qualified Streamly.Internal.Data.Stream.Serial as Serial
255import qualified Streamly.Internal.Data.Stream.Serial as Serial
256import qualified Streamly.Internal.Data.Stream.StreamD as D
256import qualified Streamly.Internal.Data.Stream.StreamD as D
257 (transform, foldrT, tap, tapOffsetEvery, pollCounts, mapM, scanOnce
257 (transform, foldrT, tap, tapOffsetEvery, pollCounts, mapM, scanOnce
src/Streamly/Internal/Data/Stream/IsStream/Type.hs+3−2
@@ -106,7 +106,8 @@ import Streamly.Internal.Data.Stream.WSerial (WSerialT(..), WSerial)
106import Streamly.Internal.Data.Stream.IsStream.Async
106import Streamly.Internal.Data.Stream.IsStream.Async
107 (AsyncT(..), Async, WAsyncT(..), WAsync)
107 (AsyncT(..), Async, WAsyncT(..), WAsync)
108import Streamly.Internal.Data.Stream.Ahead (AheadT(..), Ahead)
108import Streamly.Internal.Data.Stream.Ahead (AheadT(..), Ahead)
109−import Streamly.Internal.Data.Stream.Parallel (ParallelT(..), Parallel)
109+import Streamly.Internal.Data.Stream.IsStream.Parallel
110+ (ParallelT(..), Parallel)
110import Streamly.Internal.Data.Stream.Zip (ZipSerialM, ZipSerial)
111import Streamly.Internal.Data.Stream.Zip (ZipSerialM, ZipSerial)
111import Streamly.Internal.Data.Stream.ZipAsync (ZipAsyncM(..), ZipAsync)
112import Streamly.Internal.Data.Stream.ZipAsync (ZipAsyncM(..), ZipAsync)
112import Streamly.Internal.Data.SVar.Type (State, adaptState)
113import Streamly.Internal.Data.SVar.Type (State, adaptState)
@@ -114,7 +115,7 @@ import Streamly.Internal.Data.SVar.Type (State, adaptState)
114import qualified Prelude
115import qualified Prelude
115import qualified Streamly.Internal.Data.Stream.Ahead as Ahead
116import qualified Streamly.Internal.Data.Stream.Ahead as Ahead
116import qualified Streamly.Internal.Data.Stream.IsStream.Async as Async
117import qualified Streamly.Internal.Data.Stream.IsStream.Async as Async
117−import qualified Streamly.Internal.Data.Stream.Parallel as Parallel
118+import qualified Streamly.Internal.Data.Stream.IsStream.Parallel as Parallel
118import qualified Streamly.Internal.Data.Stream.Serial as Serial
119import qualified Streamly.Internal.Data.Stream.Serial as Serial
119import qualified Streamly.Internal.Data.Stream.WSerial as WSerial
120import qualified Streamly.Internal.Data.Stream.WSerial as WSerial
120import qualified Streamly.Internal.Data.Stream.StreamD.Type as D
121import qualified Streamly.Internal.Data.Stream.StreamD.Type as D
streamly.cabal+1−1
@@ -464,7 +464,6 @@ library
464 , Streamly.Internal.Data.Stream.Async.Channel.Operations
464 , Streamly.Internal.Data.Stream.Async.Channel.Operations
465 , Streamly.Internal.Data.Stream.Async.Channel
465 , Streamly.Internal.Data.Stream.Async.Channel
466 , Streamly.Internal.Data.Stream.Async
466 , Streamly.Internal.Data.Stream.Async
467− , Streamly.Internal.Data.Stream.Parallel
468 , Streamly.Internal.Data.Stream.Ahead
467 , Streamly.Internal.Data.Stream.Ahead
469 , Streamly.Internal.Data.Stream.ZipAsync
468 , Streamly.Internal.Data.Stream.ZipAsync
470
469
@@ -481,6 +480,7 @@ library
481 , Streamly.Internal.Data.Stream.IsStream.Lift
480 , Streamly.Internal.Data.Stream.IsStream.Lift
482 , Streamly.Internal.Data.Stream.IsStream.Top
481 , Streamly.Internal.Data.Stream.IsStream.Top
483 , Streamly.Internal.Data.Stream.IsStream.Async
482 , Streamly.Internal.Data.Stream.IsStream.Async
483+ , Streamly.Internal.Data.Stream.IsStream.Parallel
484 , Streamly.Internal.Data.Stream.IsStream
484 , Streamly.Internal.Data.Stream.IsStream
485
485
486 -- streamly-serde
486 -- streamly-serde