final Map<DOMDataTreeIdentifier, DOMDataTreeProducer> childProducers) {
this.producer = Preconditions.checkNotNull(producer);
idToTransaction = new HashMap<>();
- Preconditions.checkNotNull(idToProducer).forEach((id, prod) -> idToTransaction.put(id, prod.createTransaction()));
+ Preconditions.checkNotNull(idToProducer).forEach((id, prod) -> idToTransaction.put(
+ id, prod.createTransaction()));
this.identifier = "SHARDED-DOM-" + COUNTER.getAndIncrement();
childProducers.forEach((id, prod) -> childBoundaries.add(id.getRootIdentifier()));
}
return e.getValue();
}
}
- throw new IllegalArgumentException(String.format("Path %s is not accessible from transaction %s", prefix, this));
+ throw new IllegalArgumentException(String.format("Path %s is not accessible from transaction %s",
+ prefix, this));
}
@Override
}
@Override
- public void onFailure(final Throwable t) {
- ret.setException(t);
+ public void onFailure(final Throwable exp) {
+ ret.setException(exp);
}
});
private final DOMDataTreeWriteCursor delegate;
private final Deque<PathArgument> path = new LinkedList<>();
- public DelegatingCursor(final DOMDataTreeWriteCursor delegate, final DOMDataTreeIdentifier rootPosition) {
+ DelegatingCursor(final DOMDataTreeWriteCursor delegate, final DOMDataTreeIdentifier rootPosition) {
this.delegate = delegate;
path.addAll(rootPosition.getRootIdentifier().getPathArguments());
}
childBoundaries.forEach(id -> {
if (id.contains(yid)) {
path.removeLast();
- throw new IllegalArgumentException("Path {" + yid + "} is not available to this cursor since it's already claimed by a child producer");
+ throw new IllegalArgumentException("Path {" + yid + "} is not available to this cursor"
+ + " since it's already claimed by a child producer");
}
});
path.removeLast();