1 files changed, 11 insertions, 1 deletions
diff --git a/jsonrpc/src/main/java/com/orbekk/same/SameState.java b/jsonrpc/src/main/java/com/orbekk/same/SameState.java
index c3d03f9..9638252 100644
--- a/jsonrpc/src/main/java/com/orbekk/same/SameState.java
+++ b/jsonrpc/src/main/java/com/orbekk/same/SameState.java
@@ -143,9 +143,19 @@ public class SameState extends Thread implements UrlReceiver {
         pendingParticipants.clear();
     }
 
+    /**
+     * This method runs the pending commands to SameState.
+     *
+     * It should be called by the worker thread, but can be called directly
+     * for testing purposes to avoid threading in unit tests.
+     */
+    synchronized void internalRun() {
+        handleNewParticipants();
+    }
+
     public synchronized void run() {
         while (!stopped) {
-            handleNewParticipants();
+            internalRun();
             try {
                 wait(1000);
             } catch (InterruptedException e) {