io.pravega.client.stream.notifications

Class NotifierFactory

java.lang.Object

io.pravega.client.stream.notifications.NotifierFactory

public class NotifierFactory
extends java.lang.Object

Factory used to create different types of notifiers. To add a new notifier add a method which returns a new Notifier object which internally implements Observable

Constructor Summary

Constructors

Constructor and Description
NotifierFactory(NotificationSystem notificationSystem, java.util.function.Supplier<StateSynchronizer<io.pravega.client.stream.impl.ReaderGroupState>> stateSynchronizerSupplier)

Method Summary

Modifier and Type	Method and Description
EndOfDataNotifier	getEndOfDataNotifier(java.util.concurrent.ScheduledExecutorService executor)
SegmentNotifier	getSegmentNotifier(java.util.concurrent.ScheduledExecutorService executor)

Methods inherited from class java.lang.Object

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

Constructor Detail

NotifierFactory

public NotifierFactory(NotificationSystem notificationSystem,
                       java.util.function.Supplier<StateSynchronizer<io.pravega.client.stream.impl.ReaderGroupState>> stateSynchronizerSupplier)

Method Detail

getSegmentNotifier

public SegmentNotifier getSegmentNotifier(java.util.concurrent.ScheduledExecutorService executor)

getEndOfDataNotifier

public EndOfDataNotifier getEndOfDataNotifier(java.util.concurrent.ScheduledExecutorService executor)