File tree Expand file tree Collapse file tree 1 file changed +2
-3
lines changed
modules/core/src/main/scala Expand file tree Collapse file tree 1 file changed +2
-3
lines changed Original file line number Diff line number Diff line change @@ -95,7 +95,7 @@ object Limiter {
9595 * It's recommended to use an explicit type ascription such
9696 * as `Limiter.start[IO]` or `Limiter.start[F]` when calling
9797 * `start`, to avoid type inference issues.
98- *
98+ *
9999 * In order to avoid bursts, jobs submitted to the [[Limiter ]] are
100100 * started at regular intervals, as specified by the `minInterval`
101101 * parameter.
@@ -115,7 +115,6 @@ object Limiter {
115115 * Limiter.start[IO](minInterval = 60 every 1.minute)
116116 * }}}
117117 *
118- *
119118 * If the duration of some jobs is longer than `minInterval`,
120119 * multiple jobs will be started concurrently.
121120 * You can limit the amount of concurrency with the `maxConcurrent`
@@ -129,7 +128,7 @@ object Limiter {
129128 * you can control the maximum size of this queue with the
130129 * `maxQueued` parameter.
131130 * Once this number is reached, submitting new jobs will immediately
132- * fail with a [[LimitReachedException], so that you can in turn signal
131+ * fail with a [[LimitReachedException ]] , so that you can in turn signal
133132 * for backpressure downstream. Submission is allowed again as soon as
134133 * the number of jobs waiting goes below `maxQueued`.
135134 * `maxQueued` must be > 0. The default is no limit.
You can’t perform that action at this time.
0 commit comments