@@ -90,16 +90,17 @@
9090
9191module Streamly.Data.Stream.Concurrent
9292 (
93+ -- * Concurrency
9394 MonadAsync
9495
95− -- * Configuration
96+ -- ** Configuration
9697 , Config
9798
98− -- ** Limits
99+ -- *** Limits
99100 , maxThreads
100101 , maxBuffer
101102
102− -- ** Rate Control
103+ -- *** Rate Control
103104 , Rate(..)
104105 , rate
105106 , avgRate
@@ -107,33 +108,33 @@ module Streamly.Data.Stream.Concurrent
107108 , maxRate
108109 , constRate
109110
110− -- ** Stop behavior
111+ -- *** Stop behavior
111112 , StopWhen (..)
112113 , stopWhen
113114
114− -- ** Scheduling behavior
115+ -- *** Scheduling behavior
115116 , eager
116117 , ordered
117118 , interleaved
118119
119− -- ** Diagnostics
120+ -- *** Diagnostics
120121 , inspect
121122
122− -- * Combinators
123+ -- ** Combinators
123124 -- | Stream combinators using a concurrent channel.
124125
125− -- ** Evaluate
126+ -- *** Evaluate
126127 -- | Evaluates a stream concurrently using a channel.
127128
128129 -- , eval
129130 , parEval
130131
131− -- ** Generate
132+ -- *** Generate
132133 -- | Uses a single channel to evaluate mapped actions concurrently.
133134 , parRepeatM
134135 , parReplicateM
135136
136− -- ** Map
137+ -- *** Map
137138 -- | Uses a single channel to evaluate mapped actions concurrently.
138139
139140 -- , mapM
@@ -141,7 +142,7 @@ module Streamly.Data.Stream.Concurrent
141142 -- , sequence
142143 , parSequence
143144
144− -- ** List of streams
145+ -- *** List of streams
145146 -- | Shares a single channel across many streams.
146147
147148 -- , append
@@ -153,13 +154,13 @@ module Streamly.Data.Stream.Concurrent
153154 -- , zipWithM
154155 -- , zipWith
155156
156− -- ** Stream of streams
157− -- *** Apply
157+ -- *** Stream of streams
158+ -- **** Apply
158159
159160 -- , apply
160161 , parApply
161162
162− -- *** Concat
163+ -- **** Concat
163164 -- | Shares a single channel across many streams.
164165
165166 -- , concat