[SignalR] [Java] Log WebSocket stopped once

Author: BrennanConroy

src/SignalR/clients/java/signalr/core/src/main/java/com/microsoft/signalr/HubConnection.java

@@ -433,15 +433,14 @@ private Completable stop(String errorMessage) {
             this.state.unlock();
         }
 
-        Completable stopTask = startTask.onErrorComplete().andThen(Completable.defer(() ->
+        CompletableSubject subject = CompletableSubject.create();
+        startTask.onErrorComplete().subscribe(() ->
         {
             Completable stop = connectionState.transport.stop();
-            stop.onErrorComplete().subscribe();
-            return stop;
-        }));
-        stopTask.onErrorComplete().subscribe();
+            stop.subscribe(() -> subject.onComplete(), e -> subject.onError(e));
+        });
 
-        return stopTask;
+        return subject;
     }
 
     private void ReceiveLoop(ByteBuffer payload)

src/SignalR/clients/java/signalr/core/src/main/java/com/microsoft/signalr/WebSocketTransport.java

@@ -82,7 +82,9 @@ public void setOnClose(TransportOnClosedCallback onCloseCallback) {
 
     @Override
     public Completable stop() {
-        return webSocketClient.stop().doOnEvent(t -> logger.info("WebSocket connection stopped."));
+        Completable stop = webSocketClient.stop();
+        stop.onErrorComplete().subscribe(() -> logger.info("WebSocket connection stopped."));
+        return stop;
     }
 
     void onClose(Integer code, String reason) {