Skip to content

Commit 1003a32

Browse files
author
Nickolay Savchenko
committed
Add logs
1 parent 93e747b commit 1003a32

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

lib/src/main/java/ua/naiksoftware/stomp/StompClient.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -174,7 +174,11 @@ public Completable send(String destination, String data) {
174174
public Completable send(@NonNull StompMessage stompMessage) {
175175
Completable completable = connectionProvider.send(stompMessage.compile(legacyWhitespace));
176176
CompletableSource connectionComplete = getConnectionStream()
177-
.filter(isConnected -> isConnected)
177+
// .filter(isConnected -> isConnected)
178+
.filter(isConnected -> {
179+
Log.d(TAG, "Send " + stompMessage + "filtered " + isConnected);
180+
return isConnected;
181+
})
178182
.firstElement().ignoreElement();
179183
return completable
180184
.startWith(connectionComplete);

0 commit comments

Comments
 (0)