mirror
/
Signal-Android
kopia lustrzana https://github.com/ryukoposting/Signal-Android
1
0
Forkuj 0
Kod Zgłoszenia Packages Projekty Wydania Wiki Aktywność

Remove conversation list datasource throttler.

fork-5.53.8
Alan Evans 2020-12-14 12:47:26 -04:00
rodzic e8c75249f1
commit 7227b43bbe
1 zmienionych plików z 2 dodań i 7 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

9
app/src/main/java/org/thoughtcrime/securesms/conversationlist/ConversationListDataSource.java
Wyświetl plik

@ -22,7 +22,6 @@ import org.thoughtcrime.securesms.database.model.ThreadRecord;
import org.thoughtcrime.securesms.dependencies.ApplicationDependencies; import org.thoughtcrime.securesms.dependencies.ApplicationDependencies;
import org.thoughtcrime.securesms.recipients.Recipient; import org.thoughtcrime.securesms.recipients.Recipient;
import org.thoughtcrime.securesms.tracing.Trace; import org.thoughtcrime.securesms.tracing.Trace;
import org.thoughtcrime.securesms.util.ThrottledDebouncer;
import org.thoughtcrime.securesms.util.paging.Invalidator; import org.thoughtcrime.securesms.util.paging.Invalidator;
import org.thoughtcrime.securesms.util.paging.SizeFixResult; import org.thoughtcrime.securesms.util.paging.SizeFixResult;
@ -36,8 +35,6 @@ abstract class ConversationListDataSource extends PositionalDataSource<Conversat
public static final Executor EXECUTOR = SignalExecutors.newFixedLifoThreadExecutor("signal-conversation-list", 1, 1); public static final Executor EXECUTOR = SignalExecutors.newFixedLifoThreadExecutor("signal-conversation-list", 1, 1);
private static final ThrottledDebouncer THROTTLER = new ThrottledDebouncer(500);
private static final String TAG = Log.tag(ConversationListDataSource.class); private static final String TAG = Log.tag(ConversationListDataSource.class);
protected final ThreadDatabase threadDatabase; protected final ThreadDatabase threadDatabase;
@ -48,10 +45,8 @@ abstract class ConversationListDataSource extends PositionalDataSource<Conversat
ContentObserver contentObserver = new ContentObserver(null) { ContentObserver contentObserver = new ContentObserver(null) {
@Override @Override
public void onChange(boolean selfChange) { public void onChange(boolean selfChange) {
THROTTLER.publish(() -> { invalidate();
invalidate(); context.getContentResolver().unregisterContentObserver(this);
context.getContentResolver().unregisterContentObserver(this);
});
} }
}; };