dorkbox/Network
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

removed runBlocking, as it's no longer necessary

Browse Source
This commit is contained in:
Robinson 2021-04-29 11:26:19 +02:00
parent 402c5a0ccd
commit a5a951f863
1 changed files with 51 additions and 72 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

123
test/dorkboxTest/network/ConnectionFilterTest.kt
View File

@ -8,7 +8,6 @@ import dorkbox.network.connection.Connection
import dorkbox.network.exceptions.ClientException import dorkbox.network.exceptions.ClientException
import dorkbox.network.ipFilter.IpSubnetFilterRule import dorkbox.network.ipFilter.IpSubnetFilterRule
import kotlinx.atomicfu.atomic import kotlinx.atomicfu.atomic
import kotlinx.coroutines.runBlocking
import org.junit.Assert import org.junit.Assert
import org.junit.Test import org.junit.Test
@ -45,13 +44,11 @@ class ConnectionFilterTest : BaseTest() {
stopEndPoints() stopEndPoints()
} }
runBlocking { try {
try { client.connect(LOOPBACK)
client.connect(LOOPBACK) } catch (e: Exception) {
} catch (e: Exception) { stopEndPoints()
stopEndPoints() throw e
throw e
}
} }
} }
@ -96,13 +93,11 @@ class ConnectionFilterTest : BaseTest() {
stopEndPoints() stopEndPoints()
} }
runBlocking { try {
try { client.connect(LOOPBACK)
client.connect(LOOPBACK) } catch (e: Exception) {
} catch (e: Exception) { stopEndPoints()
stopEndPoints() throw e
throw e
}
} }
} }
@ -146,13 +141,11 @@ class ConnectionFilterTest : BaseTest() {
stopEndPoints() stopEndPoints()
} }
runBlocking { try {
try { client.connect(LOOPBACK)
client.connect(LOOPBACK) } catch (e: Exception) {
} catch (e: Exception) { stopEndPoints()
stopEndPoints() throw e
throw e
}
} }
} }
@ -196,13 +189,11 @@ class ConnectionFilterTest : BaseTest() {
stopEndPoints() stopEndPoints()
} }
runBlocking { try {
try { client.connect(LOOPBACK)
client.connect(LOOPBACK) } catch (e: Exception) {
} catch (e: Exception) { stopEndPoints()
stopEndPoints() throw e
throw e
}
} }
} }
@ -239,17 +230,15 @@ class ConnectionFilterTest : BaseTest() {
stopEndPoints() stopEndPoints()
} }
runBlocking { try {
try { client.connect(LOOPBACK, 0)
client.connect(LOOPBACK) } catch (e: Exception) {
} catch (e: Exception) { stopEndPoints()
stopEndPoints() throw e
throw e
}
} }
} }
waitForThreads() waitForThreads(0)
} }
@Test(expected = ClientException::class) @Test(expected = ClientException::class)
@ -277,13 +266,11 @@ class ConnectionFilterTest : BaseTest() {
stopEndPoints() stopEndPoints()
} }
runBlocking { try {
try { client.connect(LOOPBACK)
client.connect(LOOPBACK) } catch (e: Exception) {
} catch (e: Exception) { stopEndPoints()
stopEndPoints() throw e
throw e
}
} }
} }
@ -325,13 +312,11 @@ class ConnectionFilterTest : BaseTest() {
stopEndPoints() stopEndPoints()
} }
runBlocking { try {
try { client.connect(LOOPBACK)
client.connect(LOOPBACK) } catch (e: Exception) {
} catch (e: Exception) { stopEndPoints()
stopEndPoints() throw e
throw e
}
} }
} }
@ -377,13 +362,11 @@ class ConnectionFilterTest : BaseTest() {
stopEndPoints() stopEndPoints()
} }
runBlocking { try {
try { client.connect(LOOPBACK)
client.connect(LOOPBACK) } catch (e: Exception) {
} catch (e: Exception) { stopEndPoints()
stopEndPoints() throw e
throw e
}
} }
} }
@ -422,13 +405,11 @@ class ConnectionFilterTest : BaseTest() {
stopEndPoints() stopEndPoints()
} }
runBlocking { try {
try { client.connect(LOOPBACK)
client.connect(LOOPBACK) } catch (e: Exception) {
} catch (e: Exception) { stopEndPoints()
stopEndPoints() throw e
throw e
}
} }
} }
@ -462,13 +443,11 @@ class ConnectionFilterTest : BaseTest() {
stopEndPoints() stopEndPoints()
} }
runBlocking { try {
try { client.connect(LOOPBACK)
client.connect(LOOPBACK) } catch (e: Exception) {
} catch (e: Exception) { stopEndPoints()
stopEndPoints() throw e
throw e
}
} }
} }