Fix failable futures swallowing errors
@@ -172,7 +172,7 @@ private Functional() {
CompletableFuture<T> ret = new CompletableFuture<>();
try {
ret.complete(call.call());
- } catch (Exception e) {
+ } catch (Throwable e) {
ret.completeExceptionally(e);
}
return ret;
@@ -192,7 +192,7 @@ private Functional() {
exec.execute(() -> {
try {
ret.complete(call.call());
- } catch (Exception e) {
+ } catch (Throwable e) {
ret.completeExceptionally(e);
}
});
