Upstream/LuckPerms
1
0
Fork 0
mirror of https://github.com/LuckPerms/LuckPerms.git synced 2024-11-28 05:35:26 +01:00
Code Issues Projects Releases Wiki Activity

Fix incorrect usage of CompletableFuture#thenCombineAsync

Browse Source
This commit is contained in:
Luck 2017-09-04 17:56:01 +01:00
parent b6e1fd179e
commit 7fe5397e21
No known key found for this signature in database
GPG Key ID: EFA9B3EC5FD90F8B
1 changed files with 16 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
sponge/src/main/java/me/lucko/luckperms/sponge/service/LuckPermsSubjectData.java
View File

@ -485,10 +485,24 @@ public class LuckPermsSubjectData implements LPSubjectData {
} else { } else {
if (t instanceof User) { if (t instanceof User) {
User user = ((User) t); User user = ((User) t);
return service.getPlugin().getStorage().saveUser(user).thenCombineAsync(user.getRefreshBuffer().request(), (b, v) -> v, service.getPlugin().getScheduler().async()); return service.getPlugin().getStorage().saveUser(user).thenApplyAsync(success -> {
if (!success) {
return null;
}
user.getRefreshBuffer().request().join();
return null;
}, service.getPlugin().getScheduler().async());
} else { } else {
Group group = ((Group) t); Group group = ((Group) t);
return service.getPlugin().getStorage().saveGroup(group).thenCombineAsync(service.getPlugin().getUpdateTaskBuffer().request(), (b, v) -> v, service.getPlugin().getScheduler().async()); return service.getPlugin().getStorage().saveGroup(group).thenApplyAsync(success -> {
if (!success) {
return null;
}
service.getPlugin().getUpdateTaskBuffer().request().join();
return null;
}, service.getPlugin().getScheduler().async());
} }
} }
} }