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())