diff --git a/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/Relay.kt b/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/Relay.kt index 6d9f0fad2..6a352b6e9 100644 --- a/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/Relay.kt +++ b/ammolite/src/main/java/com/vitorpamplona/ammolite/relays/Relay.kt @@ -524,9 +524,17 @@ class Relay( } private fun writeToSocket(str: String) { + if (socket == null) { + listeners.forEach { listener -> + listener.onError( + this@Relay, + "", + Error("Failed to send $str. Relay is not connected."), + ) + } + } socket?.let { checkNotInMainThread() - val result = it.send(str) listeners.forEach { listener -> listener.onSend(this@Relay, str, result)