SergeychWorks/kiloparsec
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 6 Wiki Activity

more UDP tests

Browse Source
This commit is contained in:
Sergey Chernov 2024-08-11 19:08:49 +02:00
parent b68232653a
commit 9ddb1209c9
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/ktorSocketTest/kotlin/net/sergeych/kiloparsec/adapter/InternetTest.kt
View File

@ -154,19 +154,28 @@ class InternetrTest {
} }
} }
val uServer = UdpServer(port) val uServer = UdpServer(port)
KiloServer(cli, uServer.transportFlow) { KiloServer(cli, uServer.transportFlow) {
Session("unknown") Session("unknown")
} }
// second server
KiloServer(cli,acceptUdpDevice(uServer.port+1)) { Session("unknown2") }
val client = KiloClient<Unit>() { val client = KiloClient<Unit>() {
addErrors(cli) addErrors(cli)
connect { connectUdpDevice("localhost:$port") } connect { connectUdpDevice("localhost:$port") }
} }
val client2 = KiloClient<Unit>() { connect { connectUdpDevice("localhost:${port+1}") } }
assertEquals("start", client.call(cmdLoad)) assertEquals("start", client.call(cmdLoad))
assertEquals("start", client2.call(cmdLoad))
client.call(cmdSave, "foobar") client.call(cmdSave, "foobar")
client2.call(cmdSave, "buzz")
assertEquals("foobar", client.call(cmdLoad)) assertEquals("foobar", client.call(cmdLoad))
assertEquals("buzz", client2.call(cmdLoad))
val res = kotlin.runCatching { client.call(cmdException) } val res = kotlin.runCatching { client.call(cmdException) }
assertIs<TestException>(res.exceptionOrNull()) assertIs<TestException>(res.exceptionOrNull())