steven/csep-2025
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Added isPending to ws dataservice

Browse source
This commit is contained in:
Oskar Rasieński 2026-01-16 19:04:51 +01:00
commit cce24ab61d
1 changed files with 5 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

5
client/src/main/java/client/utils/WebSocketDataService.java
View file

@ -58,7 +58,12 @@ public class WebSocketDataService<ID, Value> {
logger.info("Item " + id + " pending propagation. Adding to pending register."); logger.info("Item " + id + " pending propagation. Adding to pending register.");
return pendingRegister.putIfAbsent(id, future) == null; return pendingRegister.putIfAbsent(id, future) == null;
} }
public boolean add(ID id) { public boolean add(ID id) {
return add(id, (_) -> {}); return add(id, (_) -> {});
} }
public boolean isPending(ID id) {
return pendingRegister.containsKey(id);
}
} }