From 7227b43bbe6af71b8ec5e2da570008b091d650cf Mon Sep 17 00:00:00 2001
From: Alan Evans <alan@signal.org>
Date: Mon, 14 Dec 2020 12:47:26 -0400
Subject: [PATCH] Remove conversation list datasource throttler.

---
 .../conversationlist/ConversationListDataSource.java     | 9 ++-------
 1 file changed, 2 insertions(+), 7 deletions(-)

diff --git a/app/src/main/java/org/thoughtcrime/securesms/conversationlist/ConversationListDataSource.java b/app/src/main/java/org/thoughtcrime/securesms/conversationlist/ConversationListDataSource.java
index 29c1894c9a..116a7ef0f0 100644
--- a/app/src/main/java/org/thoughtcrime/securesms/conversationlist/ConversationListDataSource.java
+++ b/app/src/main/java/org/thoughtcrime/securesms/conversationlist/ConversationListDataSource.java
@@ -22,7 +22,6 @@ import org.thoughtcrime.securesms.database.model.ThreadRecord;
 import org.thoughtcrime.securesms.dependencies.ApplicationDependencies;
 import org.thoughtcrime.securesms.recipients.Recipient;
 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.SizeFixResult;
 
@@ -36,8 +35,6 @@ abstract class ConversationListDataSource extends PositionalDataSource<Conversat
 
   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);
 
   protected final ThreadDatabase threadDatabase;
@@ -48,10 +45,8 @@ abstract class ConversationListDataSource extends PositionalDataSource<Conversat
     ContentObserver contentObserver = new ContentObserver(null) {
       @Override
       public void onChange(boolean selfChange) {
-        THROTTLER.publish(() -> {
-          invalidate();
-          context.getContentResolver().unregisterContentObserver(this);
-        });
+        invalidate();
+        context.getContentResolver().unregisterContentObserver(this);
       }
     };