diff --git a/lib/src/main/java/ua/naiksoftware/stomp/StompClient.java b/lib/src/main/java/ua/naiksoftware/stomp/StompClient.java index e4f73cc..87dd498 100644 --- a/lib/src/main/java/ua/naiksoftware/stomp/StompClient.java +++ b/lib/src/main/java/ua/naiksoftware/stomp/StompClient.java @@ -214,6 +214,8 @@ public void disconnect() { } public Completable disconnectCompletable() { + getConnectionStream().onNext(false); + lifecyclePublishSubject.onNext(new LifecycleEvent(LifecycleEvent.Type.CLOSED)); heartBeatTask.shutdown();