Limework/RedisBungee
2
0
Fork 0
mirror of https://github.com/proxiodev/RedisBungee.git synced 2025-04-20 01:27:07 +00:00
Code Releases Activity

Add null-check for server keys

Browse Source
This commit is contained in:
Efe Kurban 2024-06-15 04:40:57 +03:00
parent e0bca62cdb
commit c49102b5e4
1 changed files with 12 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
api/src/main/java/com/imaginarycode/minecraft/redisbungee/api/PlayerDataManager.java
View File

@ -251,7 +251,12 @@ public abstract class PlayerDataManager<P, LE, DE, PS extends IPubSubMessageEven
responses.put(uuid, pipeline.hget("redis-bungee::" + networkId + "::player::" + uuid + "::data", "server")); responses.put(uuid, pipeline.hget("redis-bungee::" + networkId + "::player::" + uuid + "::data", "server"));
} }
pipeline.sync(); pipeline.sync();
responses.forEach((uuid, response) -> builder.put(response.get(), uuid)); responses.forEach((uuid, response) -> {
String key = response.get();
if (key == null) return;
builder.put(key, uuid);
});
return builder.build(); return builder.build();
} }
@ -262,7 +267,12 @@ public abstract class PlayerDataManager<P, LE, DE, PS extends IPubSubMessageEven
responses.put(uuid, pipeline.hget("redis-bungee::" + networkId + "::player::" + uuid + "::data", "server")); responses.put(uuid, pipeline.hget("redis-bungee::" + networkId + "::player::" + uuid + "::data", "server"));
} }
pipeline.sync(); pipeline.sync();
responses.forEach((uuid, response) -> builder.put(response.get(), uuid)); responses.forEach((uuid, response) -> {
String key = response.get();
if (key == null) return;
builder.put(key, uuid);
});
return builder.build(); return builder.build();
} }
}.call(); }.call();