remove DDPClient#isConnected because it is just useless!!

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

@@ -61,10 +61,6 @@ public class DDPClient {
     return impl.getOnCloseCallback();
   }
 
-  public boolean isConnected() {
-    return impl.isConnected();
-  }
-
   public void close() {
     impl.close(1000, "closed by DDPClient#close()");
   }

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

@@ -96,10 +96,6 @@ public class DDPClientImpl {
     }
   }
 
-  public boolean isConnected() {
-    return websocket != null && websocket.isConnected();
-  }
-
   public void ping(final TaskCompletionSource<DDPClientCallback.Ping> task,
                    @Nullable final String id) {
 

android-ddp/src/main/java/chat/rocket/android_ddp/rx/RxWebSocket.java

@@ -15,11 +15,9 @@ import rx.observables.ConnectableObservable;
 public class RxWebSocket {
   private OkHttpClient httpClient;
   private WebSocket webSocket;
-  private boolean isConnected;
 
   public RxWebSocket(OkHttpClient client) {
     httpClient = client;
-    isConnected = false;
   }
 
   public ConnectableObservable<RxWebSocketCallback.Base> connect(String url) {
@@ -31,7 +29,6 @@ public class RxWebSocket {
         httpClient.newWebSocket(request, new WebSocketListener() {
           @Override
           public void onOpen(WebSocket webSocket, Response response) {
-            isConnected = true;
             RxWebSocket.this.webSocket = webSocket;
             subscriber.onNext(new RxWebSocketCallback.Open(RxWebSocket.this.webSocket, response));
           }
@@ -39,7 +36,6 @@ public class RxWebSocket {
           @Override
           public void onFailure(WebSocket webSocket, Throwable err, Response response) {
             try {
-              isConnected = false;
               subscriber.onError(new RxWebSocketCallback.Failure(webSocket, err, response));
             } catch (OnErrorNotImplementedException ex) {
               RCLog.w(ex, "OnErrorNotImplementedException ignored");
@@ -48,13 +44,11 @@ public class RxWebSocket {
 
           @Override
           public void onMessage(WebSocket webSocket, String text) {
-            isConnected = true;
             subscriber.onNext(new RxWebSocketCallback.Message(webSocket, text));
           }
 
           @Override
           public void onClosed(WebSocket webSocket, int code, String reason) {
-            isConnected = false;
             subscriber.onNext(new RxWebSocketCallback.Close(webSocket, code, reason));
             subscriber.onCompleted();
           }
@@ -67,10 +61,6 @@ public class RxWebSocket {
     return webSocket.send(message);
   }
 
-  public boolean isConnected() {
-    return isConnected;
-  }
-
   public boolean close(int code, String reason) throws IOException {
     return webSocket.close(code, reason);
   }

app/src/main/java/chat/rocket/android/api/DDPClientWrapper.java

@@ -42,13 +42,6 @@ public class DDPClientWrapper {
     return ddpClient.connect(protocol + hostname + "/websocket", session);
   }
 
-  /**
-   * Returns whether DDP client is connected to WebSocket server.
-   */
-  public boolean isConnected() {
-    return ddpClient.isConnected();
-  }
-
   /**
    * close connection.
    */

app/src/main/java/chat/rocket/android/service/RocketChatWebSocketThread.java

@@ -179,7 +179,7 @@ public class RocketChatWebSocketThread extends HandlerThread {
   }
 
   private Single<Boolean> checkIfConnectionAlive() {
-    if (ddpClient == null || !ddpClient.isConnected()) {
+    if (ddpClient == null) {
       return Single.just(false);
     }