Revert "Fix assertions which are no longer true after this commit"

This reverts commit bde8615.

Author: Matt Jacobs

hystrix-core/src/test/java/com/netflix/hystrix/HystrixTest.java

@@ -27,7 +27,6 @@
 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.*;
@@ -95,29 +94,28 @@ 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(System.currentTimeMillis() + " : " + Thread.currentThread().getName() + " OnNext : " + value);
+                System.out.println("OnNext : " + value);
                 assertTrue(value);
+                assertEquals("CommandName", Hystrix.getCurrentThreadExecutingCommand().name());
+                assertEquals(1, Hystrix.getCommandCount());
             }
         });
 
         try {
             assertNull(Hystrix.getCurrentThreadExecutingCommand());
             assertEquals(0, Hystrix.getCommandCount());
-            assertTrue(latch.await(1000, TimeUnit.MILLISECONDS));
+            latch.await();
         } catch (InterruptedException ex) {
             fail(ex.getMessage());
         }