diff --git a/lib/src/main/java/ua/naiksoftware/stomp/client/StompClient.java b/lib/src/main/java/ua/naiksoftware/stomp/client/StompClient.java index ff4c199..e83a477 100644 --- a/lib/src/main/java/ua/naiksoftware/stomp/client/StompClient.java +++ b/lib/src/main/java/ua/naiksoftware/stomp/client/StompClient.java @@ -186,8 +186,12 @@ public void disconnect() { } public Completable disconnectCompletable() { - mLifecycleDisposable.dispose(); - mMessagesDisposable.dispose(); + if (mLifecycleDisposable != null) { + mLifecycleDisposable.dispose(); + } + if (mMessagesDisposable != null) { + mMessagesDisposable.dispose(); + } return mConnectionProvider.disconnect() .doOnComplete(() -> setConnected(false)); }