@Test
public void testIfThenObservableThrows() {

    Observable<Integer> source1 = Observable.error(new RuntimeException("Forced failure!"));
    Observable<Integer> result = Statement.ifThen(condition, source1);
    observeError(result, RuntimeException.class);
    observe(result);
    observeError(result, RuntimeException.class);
    observe(result);
}