File tree Expand file tree Collapse file tree 1 file changed +12
-2
lines changed
kotlinx-coroutines-core/jvm/test Expand file tree Collapse file tree 1 file changed +12
-2
lines changed Original file line number Diff line number Diff line change 2
2
3
3
package kotlinx.coroutines
4
4
5
+ import kotlinx.coroutines.scheduling.CORE_POOL_SIZE
6
+ import kotlinx.coroutines.scheduling.MAX_POOL_SIZE
5
7
import kotlin.test.*
6
8
7
9
class DispatchersToStringTest {
@@ -16,8 +18,16 @@ class DispatchersToStringTest {
16
18
17
19
@Test
18
20
fun testLimitedParallelism () {
19
- assertEquals(" Dispatchers.IO.limitedParallelism(1)" , Dispatchers .IO .limitedParallelism(1 ).toString())
20
- assertEquals(" Dispatchers.Default.limitedParallelism(2)" , Dispatchers .Default .limitedParallelism(2 ).toString())
21
+ for (parallelism in 1 .. 100 ) {
22
+ assertEquals(
23
+ " Dispatchers.IO" + if (parallelism < MAX_POOL_SIZE ) " .limitedParallelism($parallelism )" else " " ,
24
+ Dispatchers .IO .limitedParallelism(parallelism).toString()
25
+ )
26
+ assertEquals(
27
+ " Dispatchers.Default" + if (parallelism < CORE_POOL_SIZE ) " .limitedParallelism($parallelism )" else " " ,
28
+ Dispatchers .Default .limitedParallelism(parallelism).toString()
29
+ )
30
+ }
21
31
// Not overridden at all, limited parallelism returns `this`
22
32
assertEquals(" DefaultExecutor" , (DefaultDelay as CoroutineDispatcher ).limitedParallelism(42 ).toString())
23
33
You can’t perform that action at this time.
0 commit comments