Removed unused imports and RxWebSocketCallback Failure class

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

@@ -378,12 +378,10 @@ public class DDPClientImpl {
 
   private void sendMessage(String msg, @Nullable JSONBuilder json,
                            TaskCompletionSource<?> taskForSetError) {
-    if (!sendMessage(msg, json)) {
-      if (taskForSetError != null) {
+    if (!sendMessage(msg, json) && taskForSetError != null) {
       taskForSetError.trySetError(new DDPClientCallback.Closed(client));
     }
   }
-  }
 
   private void addErrorCallback(CompositeDisposable disposables, TaskCompletionSource<?> task) {
     disposables.add(

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

 package chat.rocket.android_ddp.rx;
 
-import static android.R.attr.resizeable;
-import static android.R.attr.type;
-
 import chat.rocket.android.log.RCLog;
 import okhttp3.Response;
 import okhttp3.WebSocket;
@@ -35,27 +32,6 @@ public class RxWebSocketCallback {
     }
   }
 
-  public static class Failure extends Base {
-    public Response response;
-
-    public Failure(WebSocket websocket, Throwable err, Response response) {
-      super("Failure", websocket);
-      this.response = response;
-      if (response != null && response.body() != null) {
-        this.response.body().close();
-      }
-    }
-
-    @Override
-    public String toString() {
-      if (response != null) {
-        return "[" + type + "] " + response.message();
-      } else {
-        return super.toString();
-      }
-    }
-  }
-
   public static class Message extends Base {
     public String responseBodyString;