revert complete with empty on error

DECENTfoundation · Nov 29, 2018 · e44184f · e44184f
1 parent a746872
commit e44184f
Showing 1 changed file with 2 additions and 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
@@ -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()