TouchInstinct
/
android-templates
301
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

chat updates

This commit is contained in:
Ilia Kurtov 2017-08-10 20:02:51 +03:00
parent d4b02b2285
commit 0f4568d01a
1 changed files with 1 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/main/java/ru/touchin/templates/chat/Chat.java
View File

@ -31,7 +31,6 @@ import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
import ru.touchin.roboswag.core.log.Lc;
import ru.touchin.roboswag.core.observables.collections.Change;
import ru.touchin.roboswag.core.observables.collections.ObservableCollection;
import ru.touchin.roboswag.core.observables.collections.ObservableList;
import rx.Observable;
@ -78,11 +77,7 @@ public abstract class Chat<TOutgoingMessage> {
return Observable.from(reversedMessages)
.concatWith(sendingMessages.observeChanges().concatMap(changes -> {
final Collection<TOutgoingMessage> insertedMessages = new ArrayList<>();
for (final Change<TOutgoingMessage> change : changes.getChanges()) {
if (change.getType() == Change.Type.INSERTED) {
insertedMessages.addAll(change.getChangedItems());
}
}
insertedMessages.addAll(changes.getInsertedItems());
return insertedMessages.isEmpty() ? Observable.empty() : Observable.from(insertedMessages);
}))
//observe on some scheduler?