diff --git a/test/dorkboxTest/network/BaseTest.kt b/test/dorkboxTest/network/BaseTest.kt index 4ab55517..b5422540 100644 --- a/test/dorkboxTest/network/BaseTest.kt +++ b/test/dorkboxTest/network/BaseTest.kt @@ -205,6 +205,8 @@ abstract class BaseTest { /** * Wait for network client/server threads to shutdown for the specified time. * + * it should close as close to naturally as possible, otherwise there are problems + * * @param stopAfterSeconds how many seconds to wait, the default is 2 minutes. */ fun waitForThreads(stopAfterSeconds: Long = AUTO_FAIL_TIMEOUT) { diff --git a/test/dorkboxTest/network/MultipleServerTest.kt b/test/dorkboxTest/network/MultipleServerTest.kt index 5b6e26a8..a3d00279 100644 --- a/test/dorkboxTest/network/MultipleServerTest.kt +++ b/test/dorkboxTest/network/MultipleServerTest.kt @@ -115,7 +115,7 @@ class MultipleServerTest : BaseTest() { } } - waitForThreads(30) + waitForThreads() didSend.forEach { assertTrue(it.get()) diff --git a/test/dorkboxTest/network/rmi/RmiSpamAsyncTest.kt b/test/dorkboxTest/network/rmi/RmiSpamAsyncTest.kt index 6689353c..18a0855e 100644 --- a/test/dorkboxTest/network/rmi/RmiSpamAsyncTest.kt +++ b/test/dorkboxTest/network/rmi/RmiSpamAsyncTest.kt @@ -118,7 +118,7 @@ class RmiSpamAsyncTest : BaseTest() { client.connect() } - waitForThreads(200) + waitForThreads() Assert.assertEquals(totalRuns.toLong(), counter.get()) client.logger.error("kryos generated: ${client.config.serialization.getInitializedKryoCount()}") server.logger.error("kryos generated: ${server.config.serialization.getInitializedKryoCount()}")