Merge pull request bitrich-info#449 from mdvx/patch-5

[Kraken] Add support for Connection State

xchange-kraken/src/main/java/info/bitrich/xchangestream/kraken/KrakenStreamingExchange.java

@@ -50,7 +50,17 @@ public Completable disconnect() {
     public boolean isAlive() {
         return streamingService.isSocketOpen();
     }
-
+
+    @Override
+    public Observable<Object> connectionSuccess() {
+        return streamingService.subscribeConnectionSuccess();
+    }
+
+    @Override
+    public Observable<Throwable> reconnectFailure() {
+        return streamingService.subscribeReconnectFailure();
+    }
+
     @Override
     public SynchronizedValueFactory<Long> getNonceFactory() {
         return nonceFactory;