Realtime/src/commonMain/kotlin/io/github/jan/supabase/realtime/RealtimeImpl.kt

@@ -87,10 +87,7 @@ import kotlin.io.encoding.ExperimentalEncodingApi
                 Error while trying to connect to realtime websocket. Trying again in ${config.reconnectDelay}
                 URL: $websocketUrl
                 """.trimIndent() }
-            scope.launch {
-                disconnect()
-                connect(true)
-            }
+            reconnect()
         }
     }
 
@@ -132,10 +129,7 @@ import kotlin.io.encoding.ExperimentalEncodingApi
             } catch(e: Exception) {
                 if(!isActive) return@launch
                 Realtime.logger.e(e) { "Error while listening for messages. Trying again in ${config.reconnectDelay}" }
-                scope.launch {
-                    disconnect()
-                    connect(true)
-                }
+                reconnect()
             }
         }
     }
@@ -206,10 +200,7 @@ import kotlin.io.encoding.ExperimentalEncodingApi
             heartbeatRef = 0
             ref = 0
             Realtime.logger.e { "Heartbeat timeout. Trying to reconnect in ${config.reconnectDelay}" }
-            scope.launch {
-                disconnect()
-                connect(true)
-            }
+            reconnect()
             return
         }
         Realtime.logger.d { "Sending heartbeat" }
@@ -280,11 +271,23 @@ import kotlin.io.encoding.ExperimentalEncodingApi
     }
 
     override suspend fun send(message: RealtimeMessage) {
-        ws?.send(message)
+        try {
+            ws?.send(message)
+        } catch(e: Exception) {
+            Realtime.logger.e(e) { "Error while sending message $message. Reconnecting in ${config.reconnectDelay}" }
+            reconnect()
+        }
     }
 
     fun nextIncrementId(): Int {
         return incrementId++
     }
 
+    private fun reconnect() {
+        scope.launch {
+            disconnect()
+            connect(true)
+        }
+    }
+
 }

Supabase/src/commonMain/kotlin/io/github/jan/supabase/exceptions/HttpRequestException.kt

@@ -1,8 +1,9 @@
 package io.github.jan.supabase.exceptions
 
 import io.ktor.client.request.HttpRequestBuilder
+import kotlinx.io.IOException
 
 /**
  * An exception that is thrown when a request fails due to network issues
  */
-class HttpRequestException(message: String, request: HttpRequestBuilder): Exception("HTTP request to ${request.url.buildString()} (${request.method.value}) failed with message: $message")
+class HttpRequestException(message: String, request: HttpRequestBuilder): IOException("HTTP request to ${request.url.buildString()} (${request.method.value}) failed with message: $message")

gradle.properties

@@ -10,5 +10,5 @@ org.jetbrains.compose.experimental.uikit.enabled=true
 org.jetbrains.compose.experimental.jscanvas.enabled=true
 org.jetbrains.compose.experimental.wasm.enabled=true
 
-supabase-version = 3.1.0
+supabase-version = 3.1.1
 base-group = io.github.jan-tennert.supabase