6624d6c · streamly · git.iko.soy

core/src/Streamly/Internal/Data/Stream/StreamD/Generate.hs−1

compare with master

unifiedsplit

@@ -127,7 +127,6 @@ import Streamly.Internal.System.IO (unsafeInlineIO)

127

128#ifdef USE_UNFOLDS_EVERYWHERE

129import qualified Streamly.Internal.Data.Unfold as Unfold

130−import qualified Streamly.Internal.Data.Unfold.Enumeration as Unfold

131#endif

130#endif

132

131

133import Data.Fixed

132import Data.Fixed

core/src/Streamly/Internal/Data/Unfold.hs+2−42

@@ -16,28 +16,16 @@ module Streamly.Internal.Data.Unfold

16 -- $setup

17

18 -- * Unfold Type

19− Step(..)

19+ module Streamly.Internal.Data.Unfold.Type

20− , Unfold

21

20

22 -- * Unfolds

21 -- * Unfolds

23 -- One to one correspondence with

22 -- One to one correspondence with

24 -- "Streamly.Internal.Data.Stream.StreamD.Generate"

23 -- "Streamly.Internal.Data.Stream.StreamD.Generate"

25 -- ** Basic Constructors

24 -- ** Basic Constructors

26− , mkUnfoldM

27− , mkUnfoldrM

28− , unfoldrM

29− , unfoldr

30− , functionM

31− , function

32− , identity

33 , nilM

25 , nilM

34 , nil

26 , nil

35 , consM

27 , consM

36

28

37− -- ** From Values

38− , fromEffect

39− , fromPure

40−

41 -- ** Generators

29 -- ** Generators

42 -- | Generate a monadic stream from a seed.

30 -- | Generate a monadic stream from a seed.

43 , repeatM

31 , repeatM

@@ -49,7 +37,6 @@ module Streamly.Internal.Data.Unfold

49 , module Streamly.Internal.Data.Unfold.Enumeration

37 , module Streamly.Internal.Data.Unfold.Enumeration

50

38

51 -- ** From Containers

39 -- ** From Containers

52− , fromList

53 , fromListM

40 , fromListM

54

41

55 -- ** From Memory

42 -- ** From Memory

@@ -62,11 +49,6 @@ module Streamly.Internal.Data.Unfold

62

49

63 -- * Combinators

50 -- * Combinators

64 -- ** Mapping on Input

51 -- ** Mapping on Input

65− , lmap

66− , lmapM

67− , both

68− , first

69− , second

70 , discardFirst

52 , discardFirst

71 , discardSecond

53 , discardSecond

72 , swap

54 , swap

@@ -81,11 +63,6 @@ module Streamly.Internal.Data.Unfold

81 -- input, but that might make the common case more inconvenient.

63 -- input, but that might make the common case more inconvenient.

82

64

83 -- ** Mapping on Output

65 -- ** Mapping on Output

84− , map

85− , map2

86− , mapM

87− , mapM2

88−

89 , postscanlM'

66 , postscanlM'

90 , postscan

67 , postscan

91 , scan

68 , scan

@@ -97,8 +74,6 @@ module Streamly.Internal.Data.Unfold

97 , either

74 , either

98

75

99 -- ** Filtering

76 -- ** Filtering

100− , takeWhileM

101− , takeWhile

102 , take

77 , take

103 , filter

78 , filter

104 , filterM

79 , filterM

@@ -106,23 +81,8 @@ module Streamly.Internal.Data.Unfold

106 , dropWhile

81 , dropWhile

107 , dropWhileM

82 , dropWhileM

108

83

109− -- ** Zipping

110− , zipWithM

111− , zipWith

112−

113 -- ** Cross product

84 -- ** Cross product

114− , crossWithM

115− , crossWith

116− , cross

117 , joinInnerGeneric

85 , joinInnerGeneric

118− , crossApply

119−

120− -- ** Nesting

121− , ConcatState (..)

122− , many

123− , many2

124− , concatMapM

125− , bind

126

86

127 -- ** Resource Management

87 -- ** Resource Management

128 -- | 'bracket' is the most general resource management operation, all other

88 -- | 'bracket' is the most general resource management operation, all other

@@ -160,7 +120,7 @@ import GHC.Types (SPEC(..))

160import Streamly.Internal.Data.Fold.Type (Fold(..))

120import Streamly.Internal.Data.Fold.Type (Fold(..))

161import Streamly.Internal.Data.IOFinalizer

121import Streamly.Internal.Data.IOFinalizer

162 (newIOFinalizer, runIOFinalizer, clearingIOFinalizer)

122 (newIOFinalizer, runIOFinalizer, clearingIOFinalizer)

163−import Streamly.Internal.Data.Stream.StreamD.Type (Stream(..), Step(..))

123+import Streamly.Internal.Data.Stream.StreamD.Type (Stream(..))

164import Streamly.Internal.Data.SVar.Type (defState)

124import Streamly.Internal.Data.SVar.Type (defState)

165

125

166import qualified Control.Monad.Catch as MC

126import qualified Control.Monad.Catch as MC

core/src/Streamly/Internal/Data/Unfold/Enumeration.hs−1

@@ -65,7 +65,6 @@ import Data.Ratio

65import Data.Word

66import Numeric.Natural

67import Data.Functor.Identity (Identity(..))

68−import Streamly.Internal.Data.Stream.StreamD.Step (Step(..))

69import Streamly.Internal.Data.Unfold.Type

68import Streamly.Internal.Data.Unfold.Type

70import Prelude

69import Prelude

71 hiding (map, mapM, takeWhile, take, filter, const, zipWith

70 hiding (map, mapM, takeWhile, take, filter, const, zipWith

core/src/Streamly/Internal/Data/Unfold/Type.hs+3−7

@@ -39,17 +39,13 @@

39

40module Streamly.Internal.Data.Unfold.Type

41 (

42− -- * Setup

43− -- | To execute the code examples provided in this module in ghci, please

44− -- run the following commands first.

45− --

46− -- $setup

47−

48 -- * General Notes

42 -- * General Notes

49 -- $notes

43 -- $notes

50

44

51 -- * Type

45 -- * Type

46+ -- StreamD Step type re-exported

47+ Step(..)

52− Unfold (..)

48+ , Unfold (..)

53

49

54 -- * Basic Constructors

50 -- * Basic Constructors

55 , mkUnfoldM

51 , mkUnfoldM

core/streamly-core.cabal+1−1

@@ -292,7 +292,6 @@ library

292 , Streamly.Internal.Data.SVar.Type

293 , Streamly.Internal.Data.Stream.StreamK.Type

294 , Streamly.Internal.Data.Refold.Type

295− , Streamly.Internal.Data.Unfold.Type

296 , Streamly.Internal.Data.Producer.Type

295 , Streamly.Internal.Data.Producer.Type

297 , Streamly.Internal.Data.Producer

296 , Streamly.Internal.Data.Producer

298 , Streamly.Internal.Data.Producer.Source

297 , Streamly.Internal.Data.Producer.Source

@@ -427,6 +426,7 @@ library

427 , Streamly.Internal.Data.Stream.StreamD.Transformer

426 , Streamly.Internal.Data.Stream.StreamD.Transformer

428 , Streamly.Internal.Data.Stream.StreamD.Type

427 , Streamly.Internal.Data.Stream.StreamD.Type

429

428

429+ , Streamly.Internal.Data.Unfold.Type

430 , Streamly.Internal.Data.Unfold.Enumeration

431

432 if flag(dev)

src/Streamly/Internal/Data/SmallArray.hs+1−1

@@ -51,7 +51,7 @@ import Data.Functor.Identity (runIdentity)

51import Streamly.Data.Fold (Fold)

52import Streamly.Data.Stream (Stream)

53import Streamly.Internal.Data.Tuple.Strict (Tuple'(..))

54−import Streamly.Internal.Data.Unfold.Type (Unfold(..))

54+import Streamly.Internal.Data.Unfold (Unfold(..))

55

56import qualified Streamly.Internal.Data.Stream as D

57import qualified Streamly.Internal.Data.Fold as FL

src/Streamly/Internal/Data/Stream/IsStream/Generate.hs+1−1

@@ -92,7 +92,7 @@ where

92import Control.Monad.IO.Class (MonadIO(..))

93import Data.Void (Void)

94import Streamly.Internal.Control.Concurrent (MonadAsync)

95−import Streamly.Internal.Data.Unfold.Type (Unfold)

95+import Streamly.Internal.Data.Unfold (Unfold)

96import Streamly.Internal.Data.SVar (Rate (..))

97import Streamly.Internal.Data.Stream.IsStream.Enumeration

98 (Enumerable(..), enumerate, enumerateTo)

src/Streamly/Internal/Data/Unfold/Exception.hs+1−3

@@ -25,11 +25,9 @@ import Streamly.Internal.Control.Concurrent

25 (MonadRunInIO, MonadAsync, withRunInIO)

26import Streamly.Internal.Data.IOFinalizer.Lifted

27 (newIOFinalizer, runIOFinalizer, clearingIOFinalizer)

28−import Streamly.Internal.Data.Stream (Step(..))

29−

30import qualified Control.Monad.Catch as MC

28import qualified Control.Monad.Catch as MC

31

29

32−import Streamly.Internal.Data.Unfold.Type

30+import Streamly.Internal.Data.Unfold

33

31

34-- | Run the alloc action @a -> m c@ with async exceptions disabled but keeping

32-- | Run the alloc action @a -> m c@ with async exceptions disabled but keeping

35-- blocking operations interruptible (see 'Control.Exception.mask'). Use the

33-- blocking operations interruptible (see 'Control.Exception.mask'). Use the

src/Streamly/Internal/Data/Unfold/SVar.hs+1−1

@@ -24,7 +24,7 @@ import Streamly.Internal.Control.Concurrent (MonadAsync)

24import Streamly.Internal.Data.Stream (Step(..))

25import Streamly.Internal.Data.Time.Clock (Clock(Monotonic), getTime)

26import Streamly.Internal.Data.SVar (printSVar, cleanupSVar, sendStopToProducer)

27−import Streamly.Internal.Data.Unfold.Type (Unfold(..))

27+import Streamly.Internal.Data.Unfold (Unfold(..))

28import System.Mem (performMajorGC)

29

30import qualified Control.Monad.Catch as MC

src/Streamly/Internal/Network/Inet/TCP.hs+1−1

@@ -111,7 +111,7 @@ import Streamly.Internal.Data.Fold (Fold(..))

111import Streamly.Data.Stream (Stream)

112import Streamly.Internal.Data.Tuple.Strict (Tuple'(..))

113import Streamly.Internal.Data.Unbox (Unbox)

114−import Streamly.Internal.Data.Unfold.Type (Unfold(..))

114+import Streamly.Internal.Data.Unfold (Unfold(..))

115import Streamly.Internal.Network.Socket (SockSpec(..), accept, acceptor)

116import Streamly.Internal.System.IO (defaultChunkSize)

117

src/Streamly/Internal/Network/Socket.hs+1−1

@@ -90,7 +90,7 @@ import Streamly.Internal.Data.Array.Type (Array(..))

90import Streamly.Internal.Data.Stream.Chunked (lpackArraysChunksOf)

91import Streamly.Internal.Data.Fold (Fold)

92import Streamly.Internal.Data.Stream (Stream)

93−import Streamly.Internal.Data.Unfold.Type (Unfold(..))

93+import Streamly.Internal.Data.Unfold (Unfold(..))

94-- import Streamly.String (encodeUtf8, decodeUtf8, foldLines)

95import Streamly.Internal.System.IO (defaultChunkSize)

96

src/Streamly/Network/Inet/TCP.hs+1−1

@@ -58,7 +58,7 @@ where

58import Control.Monad.IO.Class (MonadIO(..))

59import Data.Word (Word8)

60import Network.Socket (Socket, PortNumber)

61−import Streamly.Internal.Data.Unfold.Type (Unfold(..))

61+import Streamly.Internal.Data.Unfold (Unfold(..))

62

63import Streamly.Internal.Network.Inet.TCP

64 hiding (acceptOnAddr, acceptOnPort, acceptOnPortLocal)

src/Streamly/Network/Socket.hs+1−1

@@ -136,7 +136,7 @@ where

136import Control.Monad.IO.Class (MonadIO(..))

137import Data.Word (Word8)

138import Network.Socket (Socket, SockAddr)

139−import Streamly.Internal.Data.Unfold.Type (Unfold(..))

139+import Streamly.Internal.Data.Unfold (Unfold(..))

140import Streamly.Internal.Data.Array.Type (Array(..))

141import Streamly.Internal.Data.Unbox (Unbox)

142