@Test
public void blockingAwait() {

    final BlockingMultiObserver<Integer> bmo = new BlockingMultiObserver<Integer>();
    Schedulers.single().scheduleDirect(new Runnable() {
        @Override
        public void run() {
            bmo.onSuccess(1);
        }
    }, 100, TimeUnit.MILLISECONDS);
    assertTrue(bmo.blockingAwait(1, TimeUnit.MINUTES));
}