From e44184f37234573796d42f13ce89423efca38cdf Mon Sep 17 00:00:00 2001
From: Marian Vanderka <vanderka.marian@gmail.com>
Date: Thu, 29 Nov 2018 14:49:39 +0100
Subject: [PATCH] revert complete with empty on error

---
 library/src/main/java/ch/decent/sdk/net/ws/RxWebSocket.kt | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

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()