Fix fast disconnect/reconnect

Author: NaikSoftware

lib/src/main/java/ua/naiksoftware/stomp/AbstractConnectionProvider.java

@@ -31,7 +31,6 @@ abstract class AbstractConnectionProvider implements ConnectionProvider {
     @NonNull
     @Override
     public Observable<String> messages() {
-        Log.d(TAG, "messages()");
         return mMessagesStream.startWith(initSocket().toObservable());
     }
 
@@ -52,7 +51,6 @@ public Completable disconnect() {
     }
 
     private Completable initSocket() {
-        Log.d(TAG, "innitSocket");
         return Completable
                 .fromAction(this::createWebSocketConnection);
     }

lib/src/main/java/ua/naiksoftware/stomp/OkHttpConnectionProvider.java

@@ -46,7 +46,6 @@ public void rawDisconnect() {
 
     @Override
     void createWebSocketConnection() {
-        Log.d(TAG, "createWebSocketConnection");
         Request.Builder requestBuilder = new Request.Builder()
                 .url(mUri);
 
@@ -56,7 +55,6 @@ void createWebSocketConnection() {
                 new WebSocketListener() {
                     @Override
                     public void onOpen(WebSocket webSocket, @NonNull Response response) {
-                        Log.d(TAG, "onOpen");
                         LifecycleEvent openEvent = new LifecycleEvent(LifecycleEvent.Type.OPENED);
 
                         TreeMap<String, String> headersAsMap = headersAsMap(response);
@@ -80,29 +78,27 @@ public void onMessage(WebSocket webSocket, @NonNull ByteString bytes) {
 
                     @Override
                     public void onClosed(WebSocket webSocket, int code, String reason) {
-                        Log.d(TAG, "onClosed (nullify socket)");
+                        if (webSocket != openedSocked) return;
                         openedSocked = null;
                         emitLifecycleEvent(new LifecycleEvent(LifecycleEvent.Type.CLOSED));
                     }
 
                     @Override
                     public void onFailure(WebSocket webSocket, Throwable t, Response response) {
+                        if (webSocket != openedSocked) return;
                         // in OkHttp, a Failure is equivalent to a JWS-Error *and* a JWS-Close
-                        Log.d(TAG, "onFailure (nullify socket)");
                         emitLifecycleEvent(new LifecycleEvent(LifecycleEvent.Type.ERROR, new Exception(t)));
                         openedSocked = null;
                         emitLifecycleEvent(new LifecycleEvent(LifecycleEvent.Type.CLOSED));
                     }
 
                     @Override
                     public void onClosing(final WebSocket webSocket, final int code, final String reason) {
-                        Log.d(TAG, "onClosing");
                         webSocket.close(code, reason);
                     }
                 }
 
         );
-        Log.d(TAG, "Socket inited " + openedSocked);
     }
 
     @Override

lib/src/main/java/ua/naiksoftware/stomp/client/StompClient.java

@@ -113,7 +113,6 @@ public void connect(@Nullable List<StompHeader> _headers) {
                 .subscribe(lifecycleEvent -> {
                     switch (lifecycleEvent.getType()) {
                         case OPENED:
-                            Log.d(TAG, "Socket connected, send connect command to stomp");
                             List<StompHeader> headers = new ArrayList<>();
                             headers.add(new StompHeader(StompHeader.VERSION, SUPPORTED_VERSIONS));
                             headers.add(new StompHeader(StompHeader.HEART_BEAT, "0," + heartbeat));
@@ -136,7 +135,6 @@ public void connect(@Nullable List<StompHeader> _headers) {
                     }
                 });
 
-        Log.d(TAG, "Subscribe to messages for create connection");
         isConnecting = true;
         mMessagesDisposable = mConnectionProvider.messages()
                 .map(StompMessage::from)