io.pravega.client.stream.notifications.notifier

Class EndOfDataNotifier

java.lang.Object

io.pravega.client.stream.notifications.notifier.AbstractNotifier<T>

io.pravega.client.stream.notifications.notifier.AbstractPollingNotifier<EndOfDataNotification>

io.pravega.client.stream.notifications.notifier.EndOfDataNotifier

All Implemented Interfaces:

Observable<EndOfDataNotification>

public class EndOfDataNotifier
extends AbstractPollingNotifier<EndOfDataNotification>

Field Summary

Fields inherited from class io.pravega.client.stream.notifications.notifier.AbstractNotifier

executor, notifySystem

Constructor Summary

Constructors

Constructor and Description
EndOfDataNotifier(NotificationSystem notifySystem, StateSynchronizer<io.pravega.client.stream.impl.ReaderGroupState> synchronizer, java.util.concurrent.ScheduledExecutorService executor)

Method Summary

Modifier and Type	Method and Description
java.lang.String	getType() Get the notification type.
void	pollNow() Invokes the periodic processing now in the current thread.
void	registerListener(Listener<EndOfDataNotification> listener) Register listener for notification type T.

Methods inherited from class io.pravega.client.stream.notifications.notifier.AbstractPollingNotifier

unregisterAllListeners, unregisterListener

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

EndOfDataNotifier

public EndOfDataNotifier(NotificationSystem notifySystem,
                         StateSynchronizer<io.pravega.client.stream.impl.ReaderGroupState> synchronizer,
                         java.util.concurrent.ScheduledExecutorService executor)

Method Detail

pollNow

public void pollNow()

Invokes the periodic processing now in the current thread.

registerListener

public void registerListener(Listener<EndOfDataNotification> listener)

Description copied from interface: Observable

Register listener for notification type T. Multiple listeners can be added for the same type.

Specified by:

registerListener in interface Observable<EndOfDataNotification>

Overrides:

registerListener in class AbstractNotifier<EndOfDataNotification>

Parameters:

listener - This is the listener which will be invoked incase of an Notification.

getType

public java.lang.String getType()

Description copied from interface: Observable

Get the notification type.

Returns:

Notification type.