on master help sign in
Move Streams/Async.hs to Internal/Data/Stream
f1a1951adithyaov
src/Streamly.hs+1−1
@@ -225,7 +225,7 @@ where
225import Data.Semigroup (Semigroup(..))
225import Data.Semigroup (Semigroup(..))
226import Streamly.Internal.Data.SVar (MonadAsync, Rate(..))
226import Streamly.Internal.Data.SVar (MonadAsync, Rate(..))
227import Streamly.Internal.Data.Stream.Ahead
227import Streamly.Internal.Data.Stream.Ahead
228−import Streamly.Streams.Async
228+import Streamly.Internal.Data.Stream.Async
229import Streamly.Streams.Combinators
229import Streamly.Streams.Combinators
230import Streamly.Streams.Parallel
230import Streamly.Streams.Parallel
231import Streamly.Streams.Serial
231import Streamly.Streams.Serial
src/Streamly/Streams/Async.hs → src/Streamly/Internal/Data/Stream/Async.hsrenamed+2−2
@@ -10,7 +10,7 @@
10{-# LANGUAGE UndecidableInstances #-} -- XXX
10{-# LANGUAGE UndecidableInstances #-} -- XXX
11
11
12-- |
12-- |
13−-- Module : Streamly.Streams.Async
13+-- Module : Streamly.Internal.Data.Stream.Async
14-- Copyright : (c) 2017 Harendra Kumar
14-- Copyright : (c) 2017 Harendra Kumar
15--
15--
16-- License : BSD3
16-- License : BSD3
@@ -19,7 +19,7 @@
19-- Portability : GHC
19-- Portability : GHC
20--
20--
21--
21--
22−module Streamly.Streams.Async
22+module Streamly.Internal.Data.Stream.Async
23 (
23 (
24 AsyncT
24 AsyncT
25 , Async
25 , Async
src/Streamly/Internal/Prelude.hs+1−1
@@ -447,7 +447,7 @@ import Streamly.Internal.Data.Unfold.Types (Unfold)
447import Streamly.Internal.Memory.Array.Types (Array, writeNUnsafe)
447import Streamly.Internal.Memory.Array.Types (Array, writeNUnsafe)
448-- import Streamly.Memory.Ring (Ring)
448-- import Streamly.Memory.Ring (Ring)
449import Streamly.Internal.Data.SVar (MonadAsync, State, defState, adaptState)
449import Streamly.Internal.Data.SVar (MonadAsync, State, defState, adaptState)
450−import Streamly.Streams.Async (mkAsync')
450+import Streamly.Internal.Data.Stream.Async (mkAsync')
451import Streamly.Streams.Combinators (inspectMode, maxYields)
451import Streamly.Streams.Combinators (inspectMode, maxYields)
452import Streamly.Streams.Prelude
452import Streamly.Streams.Prelude
453 (fromStreamS, toStreamS, foldWith, foldMapWith, forEachWith)
453 (fromStreamS, toStreamS, foldWith, foldMapWith, forEachWith)
streamly.cabal+1−1
@@ -289,7 +289,7 @@ library
289 -- Higher level streams
289 -- Higher level streams
290 , Streamly.Streams.SVar
290 , Streamly.Streams.SVar
291 , Streamly.Streams.Serial
291 , Streamly.Streams.Serial
292− , Streamly.Streams.Async
292+ , Streamly.Internal.Data.Stream.Async
293 , Streamly.Streams.Parallel
293 , Streamly.Streams.Parallel
294 , Streamly.Internal.Data.Stream.Ahead
294 , Streamly.Internal.Data.Stream.Ahead
295 , Streamly.Streams.Zip
295 , Streamly.Streams.Zip