HystrixCommandCompletionStream implements HystrixEventStream<HystrixCommandCompletion> { @Override public Observable<HystrixCommandCompletion> observe() { return readOnlyStream; } HystrixCommandCompletionStream(final HystrixCommandKey commandKey); static HystrixCommandCompletionStream getInstance(HystrixCommandKey commandKey); static void reset(); void write(HystrixCommandCompletion event); @Override Observable<HystrixCommandCompletion> observe(); @Override String toString();  }
@Test public void noEvents() throws InterruptedException { CountDownLatch latch = new CountDownLatch(1); Subscriber<HystrixCommandCompletion> subscriber = getLatchedSubscriber(latch); commandStream.observe().take(1).subscribe(subscriber); assertFalse(latch.await(1000, TimeUnit.MILLISECONDS)); }