Better encapsulation of completable

GuilhermeJ · GuilhermeJ · commit 4b392f3a9e47 · 2018-07-12T19:59:03.000-03:00
diff --git a/lib/src/main/java/ua/naiksoftware/stomp/OkHttpConnectionProvider.java b/lib/src/main/java/ua/naiksoftware/stomp/OkHttpConnectionProvider.java
@@ -47,7 +47,7 @@ public void rawDisconnect() {
         if (openedSocked != null) {
             openedSocked.close(1000, "");
             if (currentListener != null)
-                currentListener.getCompletable().blockingAwait();
+                currentListener.awaitCloseBlocking();
         }
     }
 
@@ -144,8 +144,8 @@ public void subscribe(CompletableEmitter emitter) {
             mEmitters.add(emitter);
         }
 
-        private Completable getCompletable(){
-            return mCompletable;
+        private void awaitCloseBlocking(){
+            mCompletable.blockingAwait();
         }
 
         private void launchCloseEvent(){

Original file line number	Diff line number	Diff line change
`@@ -47,7 +47,7 @@ public void rawDisconnect() {`
`47`	`47`	`if (openedSocked != null) {`
`48`	`48`	`openedSocked.close(1000, "");`
`49`	`49`	`if (currentListener != null)`
`50`		`- currentListener.getCompletable().blockingAwait();`
	`50`	`+ currentListener.awaitCloseBlocking();`
`51`	`51`	`}`
`52`	`52`	`}`
`53`	`53`
`@@ -144,8 +144,8 @@ public void subscribe(CompletableEmitter emitter) {`
`144`	`144`	`mEmitters.add(emitter);`
`145`	`145`	`}`
`146`	`146`
`147`		`- private Completable getCompletable(){`
`148`		`- return mCompletable;`
	`147`	`+ private void awaitCloseBlocking(){`
	`148`	`+ mCompletable.blockingAwait();`
`149`	`149`	`}`
`150`	`150`
`151`	`151`	`private void launchCloseEvent(){`