Update StompClient.java

NaikSoftware · web-flow · commit 6e6c8ea66ada · 2017-02-01T13:34:20.000+02: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
@@ -177,7 +177,7 @@ public Observable<StompMessage> topic(String destinationPath, List<StompHeader>
    }
 
     private Observable<Void> subscribePath(String destinationPath, List<StompHeader> headerList) {
-          if (destinationPath == null) return null;
+          if (destinationPath == null) return Observable.empty();
           String topicId = UUID.randomUUID().toString();
 
           if (mTopics == null) mTopics = new HashMap<>();

Original file line number	Diff line number	Diff line change
`@@ -177,7 +177,7 @@ public Observable<StompMessage> topic(String destinationPath, List<StompHeader>`
`177`	`177`	`}`
`178`	`178`
`179`	`179`	`private Observable<Void> subscribePath(String destinationPath, List<StompHeader> headerList) {`
`180`		`- if (destinationPath == null) return null;`
	`180`	`+ if (destinationPath == null) return Observable.empty();`
`181`	`181`	`String topicId = UUID.randomUUID().toString();`
`182`	`182`
`183`	`183`	`if (mTopics == null) mTopics = new HashMap<>();`