@Test
public void testFromRunnableThrows() {

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