diff --git a/test/dorkbox/util/messagebus/SynchronizedHandlerTest.java b/test/dorkbox/util/messagebus/SynchronizedHandlerTest.java index 301be01..222fda6 100644 --- a/test/dorkbox/util/messagebus/SynchronizedHandlerTest.java +++ b/test/dorkbox/util/messagebus/SynchronizedHandlerTest.java @@ -57,13 +57,26 @@ public class SynchronizedHandlerTest extends MessageBusTest { int totalCount = numberOfListeners * numberOfMessages; + System.err.println("Testing: " + totalCount); + // wait for last publication while (bus.hasPendingMessages()) { pause(100); } + // while (true) { + // synchronized (SynchronizedWithSynchronousDelivery.class) { + // if (totalCount != counter.get()) { + // System.err.println("Waiting for tally: " + (totalCount - counter.get())); + // pause(100L); + // } else { + // break; + // } + // } + // } + if (totalCount != counter.get()) { - fail("Count '" + counter.get() + "' was incorrect!"); + fail("Count '" + counter.get() + "' was incorrect! (Should be " + totalCount + ", difference of " + (totalCount - counter.get()) + ")"); } }