@Test
public void testFromFunc0Throws() {

    Func0<Integer> func = new Func0<Integer>() {
        @Override
        public Integer call() {
            throw new RuntimeException("Forced failure!");
        }
    };
    
    Observable<Integer> source = Async.fromFunc0(func, scheduler);
    
    testRunShouldThrow(source, RuntimeException.class);
}