@@ -35,8 +35,7 @@ class LimiterSuite extends BaseSuite {
3535 productionInterval : FiniteDuration ,
3636 producers : Int ,
3737 jobsPerProducer : Int ,
38- jobCompletion : FiniteDuration ,
39- samplingWindow : FiniteDuration
38+ jobCompletion : FiniteDuration
4039 ): IO [Vector [FiniteDuration ]] =
4140 Limiter .start[IO ](desiredInterval, maxConcurrent).use { limiter =>
4241 def job = IO .monotonic <* IO .sleep(jobCompletion)
@@ -52,7 +51,6 @@ class LimiterSuite extends BaseSuite {
5251 Stream (producer)
5352 .repeatN(producers.toLong)
5453 .parJoinUnbounded
55- .interruptAfter(samplingWindow)
5654
5755 def results =
5856 runProducers
@@ -95,8 +93,7 @@ class LimiterSuite extends BaseSuite {
9593 productionInterval = 1 .millis,
9694 producers = 4 ,
9795 jobsPerProducer = 100 ,
98- jobCompletion = 0 .seconds,
99- samplingWindow = 10 .seconds
96+ jobCompletion = 0 .seconds
10097 )
10198
10299 TestControl .executeEmbed(prog).map { r =>
@@ -111,8 +108,7 @@ class LimiterSuite extends BaseSuite {
111108 productionInterval = 300 .millis,
112109 producers = 1 ,
113110 jobsPerProducer = 100 ,
114- jobCompletion = 0 .seconds,
115- samplingWindow = 10 .seconds
111+ jobCompletion = 0 .seconds
116112 )
117113
118114 TestControl .executeEmbed(prog).map { r =>
@@ -127,8 +123,7 @@ class LimiterSuite extends BaseSuite {
127123 productionInterval = 1 .millis,
128124 producers = 1 ,
129125 jobsPerProducer = 10 ,
130- jobCompletion = 300 .millis,
131- samplingWindow = 10 .seconds
126+ jobCompletion = 300 .millis
132127 )
133128
134129 val expected = Vector (
0 commit comments