}
@VisibleForTesting
- @NonNull ListenableFuture<? extends Object> publish(final DOMNotification notification,
- final Collection<Reg<?>> subscribers) {
- final var futures = new ArrayList<ListenableFuture<Void>>(subscribers.size());
+ @NonNull ListenableFuture<?> publish(final DOMNotification notification, final Collection<Reg<?>> subscribers) {
+ final var futures = new ArrayList<ListenableFuture<?>>(subscribers.size());
subscribers.forEach(subscriber -> {
final var event = new DOMNotificationRouterEvent(notification);
futures.add(event.future());
queueNotificationManager.submitNotification(subscriber, event);
});
- return Futures.transform(Futures.successfulAsList(futures), ignored -> (Void)null,
+ return Futures.transform(Futures.successfulAsList(futures), ignored -> Empty.value(),
MoreExecutors.directExecutor());
}
import org.eclipse.jdt.annotation.NonNull;
import org.opendaylight.mdsal.dom.api.DOMNotification;
import org.opendaylight.mdsal.dom.api.DOMNotificationListener;
+import org.opendaylight.yangtools.yang.common.Empty;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
final class DOMNotificationRouterEvent {
private static final Logger LOG = LoggerFactory.getLogger(DOMNotificationRouterEvent.class);
- private final SettableFuture<Void> future = SettableFuture.create();
+ private final SettableFuture<Empty> future = SettableFuture.create();
private final @NonNull DOMNotification notification;
DOMNotificationRouterEvent(final DOMNotification notification) {
this.notification = requireNonNull(notification);
}
- ListenableFuture<Void> future() {
+ ListenableFuture<Empty> future() {
return future;
}
}
void clear() {
- future.set(null);
+ future.set(Empty.value());
}
}