File tree Expand file tree Collapse file tree 2 files changed +9
-3
lines changed
lib/src/main/java/ua/naiksoftware/stomp Expand file tree Collapse file tree 2 files changed +9
-3
lines changed Original file line number Diff line number Diff line change @@ -37,7 +37,9 @@ class OkHttpConnectionProvider extends AbstractConnectionProvider {
3737 @ NonNull
3838 @ Override
3939 public void rawDisconnect () {
40- openedSocked .close (1000 , "" );
40+ if (openedSocked != null ) {
41+ openedSocked .close (1000 , "" );
42+ }
4143 }
4244
4345 @ Override
Original file line number Diff line number Diff line change @@ -186,8 +186,12 @@ public void disconnect() {
186186 }
187187
188188 public Completable disconnectCompletable () {
189- mLifecycleDisposable .dispose ();
190- mMessagesDisposable .dispose ();
189+ if (mLifecycleDisposable != null ) {
190+ mLifecycleDisposable .dispose ();
191+ }
192+ if (mMessagesDisposable != null ) {
193+ mMessagesDisposable .dispose ();
194+ }
191195 return mConnectionProvider .disconnect ()
192196 .doOnComplete (() -> setConnected (false ));
193197 }
You can’t perform that action at this time.
0 commit comments