@Test
public void testFromCallableThrows() {

    Callable<Integer> callable = new Callable<Integer>() {
        @Override
        public Integer call() throws Exception {
            throw new IOException("Forced failure!");
        }
    };
    
    Observable<Integer> source = Async.fromCallable(callable, scheduler);
    
    testRunShouldThrow(source, IOException.class);
}