git.iko.soy/streamly
on master help sign in
Move Data.Stream.Async to Data.Stream.IsStream.Async
30c98dcHarendra Kumar
src/Streamly.hs+1−1
compare with master
unifiedsplit
@@ -197,7 +197,7 @@ import Data.Semigroup (Semigroup(..))
197import Streamly.Internal.Control.Concurrent (MonadAsync)
197import Streamly.Internal.Control.Concurrent (MonadAsync)
198import Streamly.Internal.Data.SVar (Rate(..))
198import Streamly.Internal.Data.SVar (Rate(..))
199import Streamly.Internal.Data.Stream.Ahead
199import Streamly.Internal.Data.Stream.Ahead
200−import Streamly.Internal.Data.Stream.Async
200+import Streamly.Internal.Data.Stream.IsStream.Async
201import Streamly.Internal.Data.Stream.IsStream.Combinators
201import Streamly.Internal.Data.Stream.IsStream.Combinators
202import Streamly.Internal.Data.Stream.IsStream.Expand
202import Streamly.Internal.Data.Stream.IsStream.Expand
203import Streamly.Internal.Data.Stream.IsStream.Type
203import Streamly.Internal.Data.Stream.IsStream.Type
src/Streamly/Internal/Data/Stream/Async.hs → src/Streamly/Internal/Data/Stream/IsStream/Async.hsrenamed+2−2
@@ -3,7 +3,7 @@
3#include "inline.hs"
3#include "inline.hs"
4
4
5-- |
5-- |
6−-- Module : Streamly.Internal.Data.Stream.Async
6+-- Module : Streamly.Internal.Data.Stream.IsStream.Async
7-- Copyright : (c) 2017 Composewell Technologies
7-- Copyright : (c) 2017 Composewell Technologies
8--
8--
9-- License : BSD3
9-- License : BSD3
@@ -22,7 +22,7 @@
22-- return n -- IO Int
22-- return n -- IO Int
23-- :}
23-- :}
24--
24--
25−module Streamly.Internal.Data.Stream.Async
25+module Streamly.Internal.Data.Stream.IsStream.Async
26 (
26 (
27 AsyncT(..)
27 AsyncT(..)
28 , Async
28 , Async
src/Streamly/Internal/Data/Stream/IsStream/Common.hs+1−1
@@ -82,7 +82,7 @@ import Streamly.Internal.Data.Unboxed (Unboxed)
82
82
83import qualified Streamly.Data.Stream as Stream (fold, foldBreak)
83import 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
85−import qualified Streamly.Internal.Data.Stream.Async as Async
85+import 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
87import qualified Streamly.Internal.Data.Stream.Parallel as Par
87import qualified Streamly.Internal.Data.Stream.Parallel as Par
88import qualified Streamly.Internal.Data.Stream.StreamK.Type as K
88import qualified Streamly.Internal.Data.Stream.StreamK.Type as K
src/Streamly/Internal/Data/Stream/IsStream/Expand.hs+1−1
@@ -165,7 +165,7 @@ where
165
165
166import Streamly.Internal.Control.Concurrent (MonadAsync)
166import Streamly.Internal.Control.Concurrent (MonadAsync)
167import Streamly.Internal.Data.Stream.Ahead (aheadK)
167import Streamly.Internal.Data.Stream.Ahead (aheadK)
168−import Streamly.Internal.Data.Stream.Async (asyncK, wAsyncK)
168+import Streamly.Internal.Data.Stream.IsStream.Async (asyncK, wAsyncK)
169import Streamly.Internal.Data.Stream.IsStream.Common
169import Streamly.Internal.Data.Stream.IsStream.Common
170 ( concatM, concatMapM, concatMap, smapM, fromPure, fromEffect, parallelFst
170 ( concatM, concatMapM, concatMap, smapM, fromPure, fromEffect, parallelFst
171 , zipWith, zipWithM)
171 , zipWith, zipWithM)
src/Streamly/Internal/Data/Stream/IsStream/Type.hs+2−2
@@ -103,7 +103,7 @@ import Streamly.Internal.Control.Concurrent (MonadAsync)
103import Streamly.Internal.Data.Fold.Type (Fold (..))
103import Streamly.Internal.Data.Fold.Type (Fold (..))
104import Streamly.Internal.Data.Stream.Serial (SerialT, Serial)
104import Streamly.Internal.Data.Stream.Serial (SerialT, Serial)
105import Streamly.Internal.Data.Stream.WSerial (WSerialT(..), WSerial)
105import Streamly.Internal.Data.Stream.WSerial (WSerialT(..), WSerial)
106−import Streamly.Internal.Data.Stream.Async
106+import 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)
109import Streamly.Internal.Data.Stream.Parallel (ParallelT(..), Parallel)
109import Streamly.Internal.Data.Stream.Parallel (ParallelT(..), Parallel)
@@ -113,7 +113,7 @@ import Streamly.Internal.Data.SVar.Type (State, adaptState)
113
113
114import qualified Prelude
114import qualified Prelude
115import qualified Streamly.Internal.Data.Stream.Ahead as Ahead
115import qualified Streamly.Internal.Data.Stream.Ahead as Ahead
116−import qualified Streamly.Internal.Data.Stream.Async as Async
116+import qualified Streamly.Internal.Data.Stream.IsStream.Async as Async
117import qualified Streamly.Internal.Data.Stream.Parallel as Parallel
117import qualified Streamly.Internal.Data.Stream.Parallel as Parallel
118import qualified Streamly.Internal.Data.Stream.Serial as Serial
118import qualified Streamly.Internal.Data.Stream.Serial as Serial
119import qualified Streamly.Internal.Data.Stream.WSerial as WSerial
119import qualified Streamly.Internal.Data.Stream.WSerial as WSerial
streamly.cabal+1−1
@@ -446,7 +446,6 @@ library
446
446
447 , Streamly.Internal.Data.Stream.Serial
447 , Streamly.Internal.Data.Stream.Serial
448 , Streamly.Internal.Data.Stream.WSerial
448 , Streamly.Internal.Data.Stream.WSerial
449− , Streamly.Internal.Data.Stream.Async
450 , Streamly.Internal.Data.Stream.Parallel
449 , Streamly.Internal.Data.Stream.Parallel
451 , Streamly.Internal.Data.Stream.Ahead
450 , Streamly.Internal.Data.Stream.Ahead
452 , Streamly.Internal.Data.Stream.ZipAsync
451 , Streamly.Internal.Data.Stream.ZipAsync
@@ -463,6 +462,7 @@ library
463 , Streamly.Internal.Data.Stream.IsStream.Exception
462 , Streamly.Internal.Data.Stream.IsStream.Exception
464 , Streamly.Internal.Data.Stream.IsStream.Lift
463 , Streamly.Internal.Data.Stream.IsStream.Lift
465 , Streamly.Internal.Data.Stream.IsStream.Top
464 , Streamly.Internal.Data.Stream.IsStream.Top
465+ , Streamly.Internal.Data.Stream.IsStream.Async
466 , Streamly.Internal.Data.Stream.IsStream
466 , Streamly.Internal.Data.Stream.IsStream
467
467
468 , Streamly.Internal.Data.Array.Stream.Foreign
468 , Streamly.Internal.Data.Array.Stream.Foreign