*/
package org.opendaylight.controller.md.sal.binding.compat;
-import java.util.Arrays;
-import java.util.Collection;
-import java.util.HashSet;
-import java.util.Set;
-
-import org.opendaylight.yangtools.yang.binding.Notification;
-
-import com.google.common.base.Predicate;
import com.google.common.cache.CacheBuilder;
import com.google.common.cache.CacheLoader;
import com.google.common.cache.LoadingCache;
import com.google.common.collect.ImmutableMultimap;
import com.google.common.collect.ImmutableSet;
-import com.google.common.collect.Iterables;
import com.google.common.collect.Multimap;
+import java.util.Arrays;
+import java.util.Collection;
+import java.util.HashSet;
+import java.util.Set;
+import java.util.stream.Collectors;
+import org.opendaylight.yangtools.yang.binding.Notification;
/**
* An immutable view of the current generation of listeners.
for (final Class<?> type : getNotificationTypes(key)) {
@SuppressWarnings("unchecked")
- final Collection<NotificationListenerRegistration<?>> l = typeToListeners.get((Class<? extends Notification>) type);
+ final Collection<NotificationListenerRegistration<?>> l =
+ typeToListeners.get((Class<? extends Notification>) type);
if (l != null) {
regs.addAll(l);
}
typeToListeners = ImmutableMultimap.of();
}
- ListenerMapGeneration(final Multimap<Class<? extends Notification>, NotificationListenerRegistration<?>> listeners) {
+ ListenerMapGeneration(final Multimap<Class<? extends Notification>,
+ NotificationListenerRegistration<?>> listeners) {
this.typeToListeners = ImmutableMultimap.copyOf(listeners);
}
private static Iterable<Class<?>> getNotificationTypes(final Class<?> cls) {
final Class<?>[] ifaces = cls.getInterfaces();
- return Iterables.filter(Arrays.asList(ifaces), new Predicate<Class<?>>() {
- @Override
- public boolean apply(final Class<?> input) {
- if (Notification.class.equals(input)) {
- return false;
- }
- return Notification.class.isAssignableFrom(input);
- }
- });
+ return Arrays.stream(ifaces)
+ .filter(input -> !Notification.class.equals(input) && Notification.class.isAssignableFrom(input))
+ .collect(Collectors.toList());
}
-}
\ No newline at end of file
+}