Forces close to happen in an IO thread

2023-11-28 22:22:28 -05:00
parent 04e70a7886
commit a02519b021
1 changed files with 5 additions and 1 deletions
@@ -362,7 +362,11 @@ class Relay(
    }

    fun close(subscriptionId: String) {
-        socket?.send("""["CLOSE","$subscriptionId"]""")
+        checkNotInMainThread()
+
+        val msg = """["CLOSE","$subscriptionId"]"""
+        Log.d("Relay", "Close Subscription $url $msg")
+        socket?.send(msg)
    }

    fun isSameRelayConfig(other: Relay): Boolean {