Fix assertions which are no longer true after this commit

rwilliams-r7 · Aug 2, 2016 · bde8615 · bde8615
1 parent 749e3db
commit bde8615
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/hystrix-core/src/test/java/com/netflix/hystrix/HystrixTest.java b/hystrix-core/src/test/java/com/netflix/hystrix/HystrixTest.java
@@ -27,6 +27,7 @@
 import java.util.ArrayList;
 import java.util.List;
 import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicBoolean;
 
 import static org.junit.Assert.*;
@@ -94,28 +95,29 @@ protected Boolean run() {
         command.observe().subscribe(new Subscriber<Boolean>() {
             @Override
             public void onCompleted() {
+                System.out.println(System.currentTimeMillis() + " : " + Thread.currentThread().getName() + " OnCompleted");
                 latch.countDown();
             }
 
             @Override
             public void onError(Throwable e) {
+                System.out.println(System.currentTimeMillis() + " : " + Thread.currentThread().getName() + " OnError : " + e);
+                e.printStackTrace();
                 fail(e.getMessage());
                 latch.countDown();
             }
 
             @Override
             public void onNext(Boolean value) {
-                System.out.println("OnNext : " + value);
+                System.out.println(System.currentTimeMillis() + " : " + Thread.currentThread().getName() + " OnNext : " + value);
                 assertTrue(value);
-                assertEquals("CommandName", Hystrix.getCurrentThreadExecutingCommand().name());
-                assertEquals(1, Hystrix.getCommandCount());
             }
         });
 
         try {
             assertNull(Hystrix.getCurrentThreadExecutingCommand());
             assertEquals(0, Hystrix.getCommandCount());
-            latch.await();
+            assertTrue(latch.await(1000, TimeUnit.MILLISECONDS));
         } catch (InterruptedException ex) {
             fail(ex.getMessage());
         }