Revert

Author: NaikSoftware

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

@@ -62,7 +62,7 @@ public Observable<String> messages() {
             }
 
             if (mMessagesSubscribers.size() < 1) {
-                Log.d(TAG, "Close web socket connection now in thread " + Thread.currentThread() + " in main loop? " + (Looper.getMainLooper() == Looper.myLooper()));
+                Log.d(TAG, "Close web socket connection now in thread " + Thread.currentThread());
                 mWebSocketClient.close();
             }
         });

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

@@ -96,7 +96,6 @@ public void connect(List<StompHeader> _headers, boolean reconnect) {
 
         isConnecting = true;
         mMessagesSubscription = mConnectionProvider.messages()
-                .unsubscribeOn(Schedulers.io())
                 .map(StompMessage::from)
                 .subscribe(stompMessage -> {
                     if (stompMessage.getStompCommand().equals(StompCommand.CONNECTED)) {