Fixed unit tests in HystrixObservableCommandTest

Netflix · Jan 7, 2015 · b5adfab · b5adfab
1 parent 595639b
commit b5adfab
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/hystrix-core/src/test/java/com/netflix/hystrix/HystrixObservableCommandTest.java b/hystrix-core/src/test/java/com/netflix/hystrix/HystrixObservableCommandTest.java
@@ -4285,7 +4285,7 @@ public void testExecutionFailureWithFallbackImplementedButDisabled() {
     /**
      * Test that we can still use thread isolation if desired.
      */
-    @Test(timeout = 500)
+    @Test
     public void testSynchronousExecutionTimeoutValueViaExecute() {
         HystrixObservableCommand.Setter properties = HystrixObservableCommand.Setter
                 .withGroupKey(HystrixCommandGroupKey.Factory.asKey("TestKey"))
@@ -4298,6 +4298,7 @@ public void testSynchronousExecutionTimeoutValueViaExecute() {
         HystrixObservableCommand<String> command = new HystrixObservableCommand<String>(properties) {
             @Override
             protected Observable<String> construct() {
+
                 return Observable.create(new OnSubscribe<String>() {
 
                     @Override
@@ -4336,7 +4337,7 @@ protected Observable<String> resumeWithFallback() {
         assertEquals(1, HystrixRequestLog.getCurrentRequest().getAllExecutedCommands().size());
     }
 
-    @Test(timeout = 500)
+    @Test
     public void testSynchronousExecutionUsingThreadIsolationTimeoutValueViaObserve() {
         HystrixObservableCommand.Setter properties = HystrixObservableCommand.Setter
                 .withGroupKey(HystrixCommandGroupKey.Factory.asKey("TestKey"))
@@ -4383,7 +4384,7 @@ protected Observable<String> resumeWithFallback() {
         assertEquals(1, HystrixRequestLog.getCurrentRequest().getAllExecutedCommands().size());
     }
 
-    @Test(timeout = 500)
+    @Test
     public void testAsyncExecutionTimeoutValueViaObserve() {
         HystrixObservableCommand.Setter properties = HystrixObservableCommand.Setter
                 .withGroupKey(HystrixCommandGroupKey.Factory.asKey("TestKey"))