lazzexus/Kafkatorio
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

replace runCatching exception swallow

Browse source
This commit is contained in:
Adam 2022-05-30 20:43:19 +02:00
parent 8c37a0cef9
commit e270b05d58
1 changed files with 3 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

4
modules/kt-rcon/src/main/kotlin/dev/adamko/ktrcon/KtRconClient.kt
View file

@ -4,6 +4,7 @@ import java.net.Socket
import kotlin.random.Random import kotlin.random.Random
import kotlin.random.nextUInt import kotlin.random.nextUInt
import kotlinx.coroutines.CoroutineScope import kotlinx.coroutines.CoroutineScope
import kotlinx.coroutines.Dispatchers
import kotlinx.coroutines.SupervisorJob import kotlinx.coroutines.SupervisorJob
import kotlinx.coroutines.cancel import kotlinx.coroutines.cancel
import kotlinx.coroutines.flow.asFlow import kotlinx.coroutines.flow.asFlow
@ -11,6 +12,7 @@ import kotlinx.coroutines.flow.launchIn
import kotlinx.coroutines.flow.onEach import kotlinx.coroutines.flow.onEach
import kotlinx.coroutines.runBlocking import kotlinx.coroutines.runBlocking
import kotlinx.coroutines.supervisorScope import kotlinx.coroutines.supervisorScope
import kotlinx.coroutines.withContext
class KtRconClient( class KtRconClient(
private val host: String, private val host: String,
@ -88,7 +90,7 @@ class KtRconClient(
// put(p.terminator) // put(p.terminator)
// } // }
runCatching { withContext(Dispatchers.IO) {
socket.getOutputStream().use { os -> socket.getOutputStream().use { os ->
os.write(bb.array()) os.write(bb.array())
os.flush() os.flush()