From 9ddb1209c9fd70403357fc1927fa0c0114150738 Mon Sep 17 00:00:00 2001 From: sergeych Date: Sun, 11 Aug 2024 19:08:49 +0200 Subject: [PATCH] more UDP tests --- .../net/sergeych/kiloparsec/adapter/InternetTest.kt | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/src/ktorSocketTest/kotlin/net/sergeych/kiloparsec/adapter/InternetTest.kt b/src/ktorSocketTest/kotlin/net/sergeych/kiloparsec/adapter/InternetTest.kt index a25bdcd..0fc930f 100644 --- a/src/ktorSocketTest/kotlin/net/sergeych/kiloparsec/adapter/InternetTest.kt +++ b/src/ktorSocketTest/kotlin/net/sergeych/kiloparsec/adapter/InternetTest.kt @@ -154,19 +154,28 @@ class InternetrTest { } } val uServer = UdpServer(port) + KiloServer(cli, uServer.transportFlow) { Session("unknown") } + // second server + KiloServer(cli,acceptUdpDevice(uServer.port+1)) { Session("unknown2") } + + val client = KiloClient() { addErrors(cli) connect { connectUdpDevice("localhost:$port") } } + val client2 = KiloClient() { connect { connectUdpDevice("localhost:${port+1}") } } assertEquals("start", client.call(cmdLoad)) + assertEquals("start", client2.call(cmdLoad)) client.call(cmdSave, "foobar") + client2.call(cmdSave, "buzz") assertEquals("foobar", client.call(cmdLoad)) + assertEquals("buzz", client2.call(cmdLoad)) val res = kotlin.runCatching { client.call(cmdException) } assertIs(res.exceptionOrNull())