From 6f4a10e9632cc2a859c1a6105ee64ae6b828d291 Mon Sep 17 00:00:00 2001 From: andrekir Date: Sun, 9 Jul 2023 09:15:52 -0300 Subject: [PATCH] refactor: replace thread with coroutines --- .../com/geeksville/mesh/repository/radio/TCPInterface.kt | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/app/src/main/java/com/geeksville/mesh/repository/radio/TCPInterface.kt b/app/src/main/java/com/geeksville/mesh/repository/radio/TCPInterface.kt index ba6d71271..19a4b89d0 100644 --- a/app/src/main/java/com/geeksville/mesh/repository/radio/TCPInterface.kt +++ b/app/src/main/java/com/geeksville/mesh/repository/radio/TCPInterface.kt @@ -2,6 +2,7 @@ package com.geeksville.mesh.repository.radio import android.content.Context import com.geeksville.mesh.android.Logging +import com.geeksville.mesh.concurrent.handledLaunch import com.geeksville.mesh.repository.usb.UsbRepository import com.geeksville.mesh.util.Exceptions import java.io.BufferedOutputStream @@ -11,8 +12,6 @@ import java.io.OutputStream import java.net.InetAddress import java.net.Socket import java.net.SocketTimeoutException -import kotlin.concurrent.thread - class TCPInterface(service: RadioInterfaceService, private val address: String) : StreamInterface(service) { @@ -59,8 +58,7 @@ class TCPInterface(service: RadioInterfaceService, private val address: String) } override fun connect() { - // No need to keep a reference to this thread - it will exit when we close inStream - thread(start = true, isDaemon = true, name = "TCP reader") { + service.serviceScope.handledLaunch { try { val a = InetAddress.getByName(address) debug("TCP connecting to $address")