@Test
public void testEmptyStreamProducesZeros() {

    HystrixCommandKey key = HystrixCommandKey.Factory.asKey("CMD-Health-A");
    stream = HealthCountsStream.getInstance(key, 10, 100);
    final CountDownLatch latch = new CountDownLatch(1);
    stream.observe().take(10).subscribe(getSubscriber(latch));
    //no writes
    try {
        assertTrue(latch.await(10000, TimeUnit.MILLISECONDS));
    } catch (InterruptedException ex) {
        fail("Interrupted ex");
    }
    System.out.println("ReqLog : " + HystrixRequestLog.getCurrentRequest().getExecutedCommandsAsString());
    assertEquals(0L, stream.getLatest().getErrorCount());
    assertEquals(0L, stream.getLatest().getTotalRequests());
}