CompletableFuture<Integer> future = CompletableFuture.supplyAsync(() -> {
});
future.exceptionally(ex -> {
});
future.handle((result, ex) -> {
if (ex != null) {
} else {
return result;
}
});
ExecutorService executor = Executors.newSingleThreadExecutor();
Future<Integer> future = executor.submit(() -> {
});
try {
} finally {
}
Observable<Integer> observable = Observable.fromCallable(() -> {
});
observable.onErrorReturn(ex -> {
});
observable.onErrorResumeNext(ex -> {
});
observable.onException(ex -> {
});
