diff --git a/client/src/main/java/client/utils/WebSocketDataService.java b/client/src/main/java/client/utils/WebSocketDataService.java index 52d0b1f..33f26a9 100644 --- a/client/src/main/java/client/utils/WebSocketDataService.java +++ b/client/src/main/java/client/utils/WebSocketDataService.java @@ -58,7 +58,12 @@ public class WebSocketDataService { logger.info("Item " + id + " pending propagation. Adding to pending register."); return pendingRegister.putIfAbsent(id, future) == null; } + public boolean add(ID id) { return add(id, (_) -> {}); } + + public boolean isPending(ID id) { + return pendingRegister.containsKey(id); + } }