From b4941178a1b6377e5ff4cd5d321b07e0ac6b71a5 Mon Sep 17 00:00:00 2001 From: Arseniy Borisov Date: Tue, 8 Nov 2016 15:13:55 +0300 Subject: [PATCH] fix typo in chat --- src/main/java/ru/touchin/templates/chat/Chat.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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()