aboutsummaryrefslogtreecommitdiffstats
path: root/kotlinx-coroutines-core/jvm/test/scheduling/SchedulerTestBase.kt
diff options
context:
space:
mode:
Diffstat (limited to 'kotlinx-coroutines-core/jvm/test/scheduling/SchedulerTestBase.kt')
-rw-r--r--kotlinx-coroutines-core/jvm/test/scheduling/SchedulerTestBase.kt12
1 files changed, 2 insertions, 10 deletions
diff --git a/kotlinx-coroutines-core/jvm/test/scheduling/SchedulerTestBase.kt b/kotlinx-coroutines-core/jvm/test/scheduling/SchedulerTestBase.kt
index bfabf5b2..dd969bdd 100644
--- a/kotlinx-coroutines-core/jvm/test/scheduling/SchedulerTestBase.kt
+++ b/kotlinx-coroutines-core/jvm/test/scheduling/SchedulerTestBase.kt
@@ -39,17 +39,9 @@ abstract class SchedulerTestBase : TestBase() {
)
}
- /**
- * Asserts that any number of pool worker threads in [range] exists at the time of method invocation
- */
- fun checkPoolThreadsExist(range: IntRange) {
- val threads = Thread.getAllStackTraces().keys.asSequence().filter { it is CoroutineScheduler.Worker }.count()
- assertTrue(threads in range, "Expected threads in $range interval, but has $threads")
- }
-
private fun maxSequenceNumber(): Int? {
return Thread.getAllStackTraces().keys.asSequence().filter { it is CoroutineScheduler.Worker }
- .map { sequenceNumber(it.name) }.max()
+ .map { sequenceNumber(it.name) }.maxOrNull()
}
private fun sequenceNumber(threadName: String): Int {
@@ -105,4 +97,4 @@ abstract class SchedulerTestBase : TestBase() {
}
}
}
-} \ No newline at end of file
+}