diff --git a/src/main/java/ru/touchin/templates/chat/Chat.java b/src/main/java/ru/touchin/templates/chat/Chat.java index b1233b2..17884a1 100644 --- a/src/main/java/ru/touchin/templates/chat/Chat.java +++ b/src/main/java/ru/touchin/templates/chat/Chat.java @@ -183,7 +183,7 @@ public abstract class Chat { private void internalSendMessage(@NonNull final TOutgoingMessage message) { final CountDownLatch blocker = new CountDownLatch(1); final Subscription subscription = Observable - .combineLatest(isMessageInActualObservable(message), isMessageInActualObservable(message), + .combineLatest(isMessageInCacheObservable(message), isMessageInActualObservable(message), (messageInCache, messageInActual) -> !messageInCache && !messageInActual) .subscribeOn(Schedulers.computation()) .first()