protected abstract DOMNotificationPublishService delegate();
@Override
- public ListenableFuture<? extends Object> putNotification(final DOMNotification notification) throws InterruptedException {
+ public ListenableFuture<?> putNotification(final DOMNotification notification) throws InterruptedException {
return delegate().putNotification(notification);
}
@Override
- public ListenableFuture<? extends Object> offerNotification(final DOMNotification notification) {
+ public ListenableFuture<?> offerNotification(final DOMNotification notification) {
return delegate().offerNotification(notification);
}
@Override
- public ListenableFuture<? extends Object> offerNotification(final DOMNotification notification, final long timeout,
+ public ListenableFuture<?> offerNotification(final DOMNotification notification, final long timeout,
final TimeUnit unit) throws InterruptedException {
return delegate().offerNotification(notification, timeout, unit);
}
RegistrationTreeNode<T> ensureChild(@Nonnull final PathArgument child) {
RegistrationTreeNode<T> potential = children.get(Preconditions.checkNotNull(child));
if (potential == null) {
- potential = new RegistrationTreeNode<T>(this, child);
+ potential = new RegistrationTreeNode<>(this, child);
children.put(child, potential);
}
return potential;
do {
entry = getSnapshot(transactionId);
- ret = new SnapshotBackedReadWriteTransaction<T>(transactionId, getDebugTransactions(), entry.getValue(), this);
+ ret = new SnapshotBackedReadWriteTransaction<>(transactionId, getDebugTransactions(), entry.getValue(),
+ this);
} while (!recordTransaction(entry.getKey(), ret));
return ret;
do {
entry = getSnapshot(transactionId);
- ret = new SnapshotBackedWriteTransaction<T>(transactionId, getDebugTransactions(), entry.getValue(), this);
+ ret = new SnapshotBackedWriteTransaction<>(transactionId, getDebugTransactions(), entry.getValue(), this);
} while (!recordTransaction(entry.getKey(), ret));
return ret;
* Unique identifier of the transaction
*/
@Override
- public Object getIdentifier();
+ Object getIdentifier();
@Override
void close();
* @param snapshot Snapshot which will be modified.
*/
public static <T> SnapshotBackedReadTransaction<T> newReadTransaction(final T identifier, final boolean debug, final DataTreeSnapshot snapshot) {
- return new SnapshotBackedReadTransaction<T>(identifier, debug, snapshot);
+ return new SnapshotBackedReadTransaction<>(identifier, debug, snapshot);
}
/**
*/
public static <T> SnapshotBackedReadWriteTransaction<T> newReadWriteTransaction(final T identifier, final boolean debug,
final DataTreeSnapshot snapshot, final TransactionReadyPrototype<T> readyImpl) {
- return new SnapshotBackedReadWriteTransaction<T>(identifier, debug, snapshot, readyImpl);
+ return new SnapshotBackedReadWriteTransaction<>(identifier, debug, snapshot, readyImpl);
}
/**
*/
public static <T> SnapshotBackedWriteTransaction<T> newWriteTransaction(final T identifier, final boolean debug,
final DataTreeSnapshot snapshot, final TransactionReadyPrototype<T> readyImpl) {
- return new SnapshotBackedWriteTransaction<T>(identifier, debug, snapshot, readyImpl);
+ return new SnapshotBackedWriteTransaction<>(identifier, debug, snapshot, readyImpl);
}
}