Fix reference to CompletableCommand

nmcl · May 9, 2017 · 1aeabfa · 1aeabfa
1 parent cac455d
commit 1aeabfa
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/hystrix-core/src/test/java/com/netflix/hystrix/HystrixObservableCommandTest.java b/hystrix-core/src/test/java/com/netflix/hystrix/HystrixObservableCommandTest.java
@@ -128,7 +128,7 @@ public void testCompletable() throws InterruptedException {
         final CountDownLatch latch = new CountDownLatch(1);
         final HystrixObservableCommand<Integer> command = new CompletableCommand();
 
-        (new CompletableCommand()).observe().subscribe(new Subscriber<Integer>() {
+        command.observe().subscribe(new Subscriber<Integer>() {
             @Override
             public void onCompleted() {
                 System.out.println(System.currentTimeMillis() + " : " + Thread.currentThread().getName() + " OnCompleted");