@Test
public void testWhileDoConditionThrowsImmediately() {

    Observable<Integer> source1 = Observable.from(1, 2, 3);
    conditionError.call();
    Observable<Integer> result = Statement.whileDo(source1, conditionError);
    observeError(result, RuntimeException.class);
}