@Test
public void noEvents() throws InterruptedException {

    CountDownLatch latch = new CountDownLatch(1);
    Subscriber<HystrixCommandCompletion> subscriber = getLatchedSubscriber(latch);
    commandStream.observe().take(1).subscribe(subscriber);
    //no writes
    assertFalse(latch.await(1000, TimeUnit.MILLISECONDS));
}