Class AbstractPollingNotifier<T extends Notification>
- java.lang.Object
-
- io.pravega.client.stream.notifications.notifier.AbstractNotifier<T>
-
- io.pravega.client.stream.notifications.notifier.AbstractPollingNotifier<T>
-
- All Implemented Interfaces:
Observable<T>
- Direct Known Subclasses:
EndOfDataNotifier
,SegmentNotifier
public abstract class AbstractPollingNotifier<T extends Notification> extends AbstractNotifier<T>
-
-
Field Summary
-
Fields inherited from class io.pravega.client.stream.notifications.notifier.AbstractNotifier
executor, notifySystem
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
unregisterAllListeners()
Remove all listeners for a given type.void
unregisterListener(Listener<T> listener)
Remove a listener.-
Methods inherited from class io.pravega.client.stream.notifications.notifier.AbstractNotifier
registerListener
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface io.pravega.client.stream.notifications.Observable
getType
-
-
-
-
Method Detail
-
unregisterListener
public void unregisterListener(Listener<T> listener)
Description copied from interface:Observable
Remove a listener.- Specified by:
unregisterListener
in interfaceObservable<T extends Notification>
- Overrides:
unregisterListener
in classAbstractNotifier<T extends Notification>
- Parameters:
listener
- the listener which needs to be removed.
-
unregisterAllListeners
public void unregisterAllListeners()
Description copied from interface:Observable
Remove all listeners for a given type.- Specified by:
unregisterAllListeners
in interfaceObservable<T extends Notification>
- Overrides:
unregisterAllListeners
in classAbstractNotifier<T extends Notification>
-
-