Fix some timing issues around recipient events.

This commit is contained in:
Greyson Parrelli
2021-07-19 12:40:11 -04:00
parent c2a6963a6d
commit 39709c8d64
2 changed files with 13 additions and 5 deletions

View File

@@ -50,9 +50,11 @@ public final class LiveRecipient {
this.groupDatabase = DatabaseFactory.getGroupDatabase(context);
this.observers = new CopyOnWriteArraySet<>();
this.foreverObserver = recipient -> {
for (RecipientForeverObserver o : observers) {
o.onRecipientChanged(recipient);
}
ThreadUtil.postToMain(() -> {
for (RecipientForeverObserver o : observers) {
o.onRecipientChanged(recipient);
}
});
};
this.refreshForceNotify = new MutableLiveData<>(new Object());
this.observableLiveData = LiveDataUtil.combineLatest(LiveDataUtil.distinctUntilChanged(liveData, Recipient::hasSameContent),