@Test
public void testFromActionThrows() {

    Action0 action = new Action0() {
        @Override
        public void call() {
            throw new RuntimeException("Forced failure!");
        }
    };
    
    Observable<Integer> source = Async.fromAction(action, 1, scheduler);
    
    testRunShouldThrow(source, RuntimeException.class);
}