@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); }
public static <R> OnSubscribeFunc<R> fromAction(Action0 action, R result) { return new InvokeAsync<R>(Actions.toFunc(action, result)); }
OperationFromFunctionals { public static <R> OnSubscribeFunc<R> fromAction(Action0 action, R result) { return new InvokeAsync<R>(Actions.toFunc(action, result)); } }
OperationFromFunctionals { public static <R> OnSubscribeFunc<R> fromAction(Action0 action, R result) { return new InvokeAsync<R>(Actions.toFunc(action, result)); } private  OperationFromFunctionals(); }
OperationFromFunctionals { public static <R> OnSubscribeFunc<R> fromAction(Action0 action, R result) { return new InvokeAsync<R>(Actions.toFunc(action, result)); } private  OperationFromFunctionals(); static OnSubscribeFunc<R> fromAction(Action0 action, R result); static OnSubscribeFunc<R> fromFunc0(Func0<? extends R> function); static OnSubscribeFunc<R> fromCallable(Callable<? extends R> callable); static OnSubscribeFunc<R> fromRunnable(final Runnable run, final R result); }
OperationFromFunctionals { public static <R> OnSubscribeFunc<R> fromAction(Action0 action, R result) { return new InvokeAsync<R>(Actions.toFunc(action, result)); } private  OperationFromFunctionals(); static OnSubscribeFunc<R> fromAction(Action0 action, R result); static OnSubscribeFunc<R> fromFunc0(Func0<? extends R> function); static OnSubscribeFunc<R> fromCallable(Callable<? extends R> callable); static OnSubscribeFunc<R> fromRunnable(final Runnable run, final R result);  }