diff options
Diffstat (limited to 'jsonrpc/src/main/java/com')
-rw-r--r-- | jsonrpc/src/main/java/com/orbekk/same/SameState.java | 12 |
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) { |