Fix def value

NaikSoftware · NaikSoftware · commit 5d4b938697b8 · 2018-04-03T21:04:09.000+03:00
diff --git a/lib/src/main/java/ua/naiksoftware/stomp/client/StompClient.java b/lib/src/main/java/ua/naiksoftware/stomp/client/StompClient.java
@@ -175,7 +175,7 @@ public Flowable<LifecycleEvent> lifecycle() {
     public void disconnect() {
         mLifecycleDisposable.dispose();
         mMessagesDisposable.dispose();
-        mConnectionProvider.disconnect().subscribe(() -> mConnected = false);
+        mConnectionProvider.disconnect().subscribe(() -> mConnected = false, e -> Log.e(tag, "Disconnect error", e));
     }
 
     public Flowable<StompMessage> topic(String destinationPath) {

Original file line number	Diff line number	Diff line change
`@@ -175,7 +175,7 @@ public Flowable<LifecycleEvent> lifecycle() {`
`175`	`175`	`public void disconnect() {`
`176`	`176`	`mLifecycleDisposable.dispose();`
`177`	`177`	`mMessagesDisposable.dispose();`
`178`		`- mConnectionProvider.disconnect().subscribe(() -> mConnected = false);`
	`178`	`+ mConnectionProvider.disconnect().subscribe(() -> mConnected = false, e -> Log.e(tag, "Disconnect error", e));`
`179`	`179`	`}`
`180`	`180`
`181`	`181`	`public Flowable<StompMessage> topic(String destinationPath) {`