From b0d09853e412b1f8acf83fad03532ce756dbb070 Mon Sep 17 00:00:00 2001
From: Zlatin Balevsky <zlatinb@gmail.com>
Date: Sun, 15 Dec 2019 23:28:00 +0000
Subject: [PATCH] pause after publishing all trust events

---
 webui/src/main/java/com/muwire/webui/TrustServlet.java | 6 +++---
 webui/src/main/java/com/muwire/webui/Util.java         | 6 ++++++
 2 files changed, 9 insertions(+), 3 deletions(-)

diff --git a/webui/src/main/java/com/muwire/webui/TrustServlet.java b/webui/src/main/java/com/muwire/webui/TrustServlet.java
index 27adf02b..18424a67 100644
--- a/webui/src/main/java/com/muwire/webui/TrustServlet.java
+++ b/webui/src/main/java/com/muwire/webui/TrustServlet.java
@@ -191,15 +191,14 @@ public class TrustServlet extends HttpServlet {
             event.setPersona(p);
             event.setSubscribe(true);
             core.getEventBus().publish(event);
+            Util.pause();
         } else if (action.equals("unsubscribe")) {
             core.getMuOptions().getTrustSubscriptions().remove(p);
             TrustSubscriptionEvent event = new TrustSubscriptionEvent();
             event.setPersona(p);
             event.setSubscribe(false);
             core.getEventBus().publish(event);
-            try {
-                Thread.sleep(100);
-            } catch (InterruptedException e) {}
+            Util.pause();
         } else if (action.equals("trust")) {
             doTrust(p, TrustLevel.TRUSTED, req.getParameter("reason"));
         } else if (action.equals("neutral")) {
@@ -215,6 +214,7 @@ public class TrustServlet extends HttpServlet {
         event.setPersona(p);
         event.setReason(reason);
         core.getEventBus().publish(event);
+        Util.pause();
     }
 
     @Override
diff --git a/webui/src/main/java/com/muwire/webui/Util.java b/webui/src/main/java/com/muwire/webui/Util.java
index 4d7d85dd..88a7f871 100644
--- a/webui/src/main/java/com/muwire/webui/Util.java
+++ b/webui/src/main/java/com/muwire/webui/Util.java
@@ -12,6 +12,12 @@ import net.i2p.data.DataHelper;
 import net.i2p.util.Translate;
 
 public class Util {
+    
+    static void pause() {
+        try {
+            Thread.sleep(100);
+        } catch (InterruptedException e) {}
+    }
 
     private static final I2PAppContext _context = I2PAppContext.getGlobalContext();