mirror of
https://github.com/composewell/streamly.git
synced 2024-08-17 07:20:36 +03:00
Move the Parallel module under IsStream
This commit is contained in:
parent
05ff41e946
commit
e718389b2c
@ -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.Parallel as Stream
|
||||
import qualified Streamly.Internal.Data.Stream.IsStream.Parallel as Stream
|
||||
import qualified Streamly.Internal.Data.Stream as Stream
|
||||
#endif
|
||||
|
||||
|
@ -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.Parallel as Par
|
||||
import qualified Streamly.Internal.Data.Stream.IsStream.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
|
||||
|
@ -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.Parallel as Par
|
||||
import qualified Streamly.Internal.Data.Stream.IsStream.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
|
||||
|
@ -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.Parallel as Par
|
||||
import qualified Streamly.Internal.Data.Stream.IsStream.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
|
||||
|
@ -1,7 +1,7 @@
|
||||
{-# LANGUAGE UndecidableInstances #-}
|
||||
|
||||
-- |
|
||||
-- Module : Streamly.Internal.Data.Stream.Parallel
|
||||
-- Module : Streamly.Internal.Data.Stream.IsStream.Parallel
|
||||
-- Copyright : (c) 2017 Composewell Technologies
|
||||
--
|
||||
-- License : BSD3
|
||||
@ -20,7 +20,7 @@
|
||||
-- return n -- IO Int
|
||||
-- :}
|
||||
--
|
||||
module Streamly.Internal.Data.Stream.Parallel
|
||||
module Streamly.Internal.Data.Stream.IsStream.Parallel
|
||||
(
|
||||
-- * Parallel Stream Type
|
||||
ParallelT(..)
|
||||
@ -545,7 +545,7 @@ parallelFst m1 m2 =
|
||||
-- seconds.
|
||||
--
|
||||
-- >>> import qualified Streamly.Data.Fold as Fold
|
||||
-- >>> import qualified Streamly.Internal.Data.Stream.Parallel as Parallel
|
||||
-- >>> import qualified Streamly.Internal.Data.Stream.IsStream.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
|
||||
--
|
@ -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.Parallel as Par
|
||||
import qualified Streamly.Internal.Data.Stream.IsStream.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
|
||||
|
@ -106,7 +106,8 @@ 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.Parallel (ParallelT(..), Parallel)
|
||||
import Streamly.Internal.Data.Stream.IsStream.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)
|
||||
@ -114,7 +115,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.Parallel as Parallel
|
||||
import qualified Streamly.Internal.Data.Stream.IsStream.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
|
||||
|
@ -464,7 +464,6 @@ library
|
||||
, Streamly.Internal.Data.Stream.Async.Channel.Operations
|
||||
, Streamly.Internal.Data.Stream.Async.Channel
|
||||
, Streamly.Internal.Data.Stream.Async
|
||||
, Streamly.Internal.Data.Stream.Parallel
|
||||
, Streamly.Internal.Data.Stream.Ahead
|
||||
, Streamly.Internal.Data.Stream.ZipAsync
|
||||
|
||||
@ -481,6 +480,7 @@ 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-serde
|
||||
|
Loading…
Reference in New Issue
Block a user