From 0c05cce13bcb26354a1089051fc20c28e37885fc Mon Sep 17 00:00:00 2001 From: sergeych Date: Tue, 14 Nov 2023 02:54:18 +0300 Subject: [PATCH] cancellability experiments in tests --- .../sergeych/kiloparsec/adapters/NetworkTest.kt | 15 ++++++--------- 1 file changed, 6 insertions(+), 9 deletions(-) diff --git a/src/jvmTest/kotlin/net/sergeych/kiloparsec/adapters/NetworkTest.kt b/src/jvmTest/kotlin/net/sergeych/kiloparsec/adapters/NetworkTest.kt index 97f71de..d66af99 100644 --- a/src/jvmTest/kotlin/net/sergeych/kiloparsec/adapters/NetworkTest.kt +++ b/src/jvmTest/kotlin/net/sergeych/kiloparsec/adapters/NetworkTest.kt @@ -2,12 +2,8 @@ package net.sergeych.kiloparsec.adapters import com.ionspin.kotlin.crypto.util.decodeFromUByteArray import com.ionspin.kotlin.crypto.util.encodeToUByteArray -import kotlinx.coroutines.cancel -import kotlinx.coroutines.coroutineScope -import kotlinx.coroutines.flow.cancellable -import kotlinx.coroutines.launch +import kotlinx.coroutines.* import kotlinx.coroutines.test.runTest -import kotlinx.coroutines.yield import net.sergeych.kiloparsec.adapter.UdpServer import net.sergeych.kiloparsec.adapter.acceptTcpDevice import net.sergeych.kiloparsec.adapter.connectTcpDevice @@ -38,8 +34,8 @@ class NetworkTest { Log.connectConsole(Log.Level.DEBUG) coroutineScope { - val serverFlow = acceptTcpDevice(17171).cancellable() - launch { + val serverFlow = acceptTcpDevice(17171) + val j = launch { serverFlow.collect { device -> println("collected input: $device") device.output.send("Hello, world!".encodeToUByteArray()) @@ -70,8 +66,9 @@ class NetworkTest { println("--1") assertEquals("Great", s.input.receive()!!.decodeFromUByteArray()) println("--2") - s.output.send("die".encodeToUByteArray()) -// s.close() +// s.output.send("die".encodeToUByteArray()) + s.close() + j.cancelAndJoin() } } } \ No newline at end of file