Upstream/Plan
1
0
Fork 0
mirror of https://github.com/plan-player-analytics/Plan.git synced 2024-09-30 15:37:50 +02:00
Code Issues Projects Releases Wiki Activity

Use exceptionally instead of handle in SQLDB

Browse Source 
The wrong method was in use for error handling completable future
This commit is contained in:
Risto Lahtela 2021-04-23 09:01:59 +03:00
parent bd7336b411
commit 9ccbda0ebd
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
Plan/common/src/main/java/com/djrapitops/plan/storage/database/SQLDB.java
View File

@ -47,7 +47,7 @@ import java.util.List;
import java.util.Objects; import java.util.Objects;
import java.util.Optional; import java.util.Optional;
import java.util.concurrent.*; import java.util.concurrent.*;
import java.util.function.BiFunction; import java.util.function.Function;
import java.util.function.Supplier; import java.util.function.Supplier;
/** /**
@ -261,11 +261,11 @@ public abstract class SQLDB extends AbstractDatabase {
accessLock.checkAccess(transaction); accessLock.checkAccess(transaction);
transaction.executeTransaction(this); transaction.executeTransaction(this);
return CompletableFuture.completedFuture(null); return CompletableFuture.completedFuture(null);
}, getTransactionExecutor()).handle(errorHandler(transaction, origin)); }, getTransactionExecutor()).exceptionally(errorHandler(transaction, origin));
} }
private BiFunction<CompletableFuture<Object>, Throwable, CompletableFuture<Object>> errorHandler(Transaction transaction, Exception origin) { private Function<Throwable, CompletableFuture<Object>> errorHandler(Transaction transaction, Exception origin) {
return (obj, throwable) -> { return throwable -> {
if (throwable == null) { if (throwable == null) {
return CompletableFuture.completedFuture(null); return CompletableFuture.completedFuture(null);
} }