return new ListenerRegistry<>(requireNonNull(name));
}
+ @Deprecated(forRemoval = true)
public @NonNull Set<? extends ListenerRegistration<? extends T>> getRegistrations() {
return unmodifiableView;
}
+ public void clear() {
+ listeners.stream().forEach(ListenerRegistration::close);
+ }
+
public boolean isEmpty() {
return listeners.isEmpty();
}
return listeners.stream().map(ListenerRegistration::getInstance);
}
- public <L extends T> @NonNull ListenerRegistration<L> register(final L listener) {
+ public <L extends T> @NonNull ListenerRegistration<L> register(final L listener) {
final ListenerRegistration<L> ret = new ListenerRegistrationImpl<>(listener, listeners::remove);
listeners.add(ret);
return ret;
import org.opendaylight.yangtools.concepts.ListenerRegistration;
public class ListenerRegistryTest {
- private TestEventListener testEventListener;
private ExtendedTestEventListener extendedTestEventListener;
private ListenerRegistry<TestEventListener> registry;
@Before
public void init() {
- testEventListener = new TestEventListener() {};
extendedTestEventListener = new ExtendedTestEventListener() {};
registry = ListenerRegistry.create();
}
}
@Test
- public void tetGetListenersMethod() {
+ public void testGetListenersMethod() {
assertEquals("Listener registry should have any listeners.", ImmutableSet.of(), registry.getRegistrations());
}