@Test
public void testLongTimeAction() throws InterruptedException {

    final CountDownLatch latch = new CountDownLatch(1);
    LongTimeAction action = new LongTimeAction(latch);
    Observable.from(1).buffer(10, TimeUnit.MILLISECONDS, 10)
            .subscribe(action);
    latch.await();
    assertFalse(action.fail);
}