diff --git a/library/src/main/java/ch/decent/sdk/net/ws/RxWebSocket.kt b/library/src/main/java/ch/decent/sdk/net/ws/RxWebSocket.kt
index 1b2839fd..2e4db009 100644
--- a/library/src/main/java/ch/decent/sdk/net/ws/RxWebSocket.kt
+++ b/library/src/main/java/ch/decent/sdk/net/ws/RxWebSocket.kt
@@ -106,7 +106,8 @@ internal class RxWebSocket(
   private fun connect() {
     disposable.addAll(
         events.log("RxWebSocket")
-            .doOnTerminate {
+            .onErrorResumeNext(Flowable.empty())
+            .doOnComplete {
               webSocketAsync = null
               disposable.clear()
               apiId.clear()