}
@Override
- public void execute(ReadGraph graph, Set<Resource> newComponents) {
+ public void execute(ReadGraph graph, Set<Resource> newComponents) throws DatabaseException {
if (currentlyListening.isEmpty() && newComponents.isEmpty()) {
// we can stop here as nothing will change
return;
for (Resource addedComponent : addedComponents) {
SCLValueDisposableSyncListener listener = new SCLValueDisposableSyncListener(callback);
currentlyListening.put(addedComponent, listener);
- graph.asyncRequest(new SCLValueRequest(addedComponent), listener);
+ graph.syncRequest(new SCLValueRequest(addedComponent), listener);
}
}