Package io.pravega.client.stream.notifications.notifier

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

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 interface Observable<T extends Notification>

Overrides:

unregisterListener in class AbstractNotifier<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 interface Observable<T extends Notification>

Overrides:

unregisterAllListeners in class AbstractNotifier<T extends Notification>