The ddp client was silently ignoring error callbacks. Throwing up an error in...

The ddp client was silently ignoring error callbacks. Throwing up an error in case at least a closed websocket issue arises

android-ddp/src/main/java/chat/rocket/android_ddp/DDPClientImpl.java

@@ -387,6 +387,9 @@ public class DDPClientImpl {
     disposables.add(
         flowable.subscribe(
             base -> {
+              if (base instanceof RxWebSocketCallback.Close) {
+                task.trySetError(new Exception(((RxWebSocketCallback.Close) base).reason));
+              }
             },
             err -> {
               task.trySetError(new Exception(err));