git.iko.soy/streamly
on master help sign in
Revert "Move Data.Stream.Async to Data.Stream.IsStream.Async"
98da856Harendra 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.IsStream.Async
200+import Streamly.Internal.Data.Stream.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/IsStream/Async.hs → src/Streamly/Internal/Data/Stream/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.IsStream.Async
6+-- Module : Streamly.Internal.Data.Stream.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.IsStream.Async
25+module Streamly.Internal.Data.Stream.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.IsStream.Async as Async
85+import qualified Streamly.Internal.Data.Stream.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.IsStream.Async (asyncK, wAsyncK)
168+import Streamly.Internal.Data.Stream.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.IsStream.Async
106+import Streamly.Internal.Data.Stream.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.IsStream.Async as Async
116+import qualified Streamly.Internal.Data.Stream.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
@@ -345,6 +345,7 @@ library
345
345
346 , Streamly.Internal.Data.Stream.Serial
346 , Streamly.Internal.Data.Stream.Serial
347 , Streamly.Internal.Data.Stream.WSerial
347 , Streamly.Internal.Data.Stream.WSerial
348+ , Streamly.Internal.Data.Stream.Async
348 , Streamly.Internal.Data.Stream.Parallel
349 , Streamly.Internal.Data.Stream.Parallel
349 , Streamly.Internal.Data.Stream.Channel.Types
350 , Streamly.Internal.Data.Stream.Channel.Types
350 , Streamly.Internal.Data.Stream.Channel.Dispatcher
351 , Streamly.Internal.Data.Stream.Channel.Dispatcher
@@ -373,7 +374,6 @@ library
373 , Streamly.Internal.Data.Stream.IsStream.Exception
374 , Streamly.Internal.Data.Stream.IsStream.Exception
374 , Streamly.Internal.Data.Stream.IsStream.Lift
375 , Streamly.Internal.Data.Stream.IsStream.Lift
375 , Streamly.Internal.Data.Stream.IsStream.Top
376 , Streamly.Internal.Data.Stream.IsStream.Top
376− , Streamly.Internal.Data.Stream.IsStream.Async
377 , Streamly.Internal.Data.Stream.IsStream
377 , Streamly.Internal.Data.Stream.IsStream
378
378
379 -- streamly-unicode
379 -- streamly-unicode