*/
default <T extends DataObject> void onAddOrUpdate(LogicalDatastoreType store, InstanceIdentifier<T> path,
BiConsumer<@Nullable T, T> callback) {
- onUpdate(store, path, (t1, t2) -> {
+ onAddOrUpdate(store, path, (t1, t2) -> {
callback.accept(t1, t2);
return UNREGISTER;
});
default <T extends DataObject> void onAddOrUpdate(LogicalDatastoreType store, InstanceIdentifier<T> path,
BiConsumer<@Nullable T, T> callback,
Duration timeoutDuration, Consumer<DataTreeIdentifier<T>> timedOutCallback) {
- onUpdate(store, path, (t1, t2) -> {
+ onAddOrUpdate(store, path, (t1, t2) -> {
callback.accept(t1, t2);
return UNREGISTER;
}, timeoutDuration, timedOutCallback);
BiFunction<@org.eclipse.jdt.annotation.Nullable T, T, NextAction> callback, Duration timeoutDuration,
Consumer<DataTreeIdentifier<T>> timedOutCallback) {
validateTimeout(timeoutDuration);
- on(Operation.ADD_OR_UPDATE, store, path, callback, Duration.ZERO,
+ on(Operation.ADD_OR_UPDATE, store, path, callback, timeoutDuration,
requireNonNull(timedOutCallback, "timedOutCallback"));
}