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 implementsObservable
-
-
Constructor Summary
Constructors Constructor Description NotifierFactory(NotificationSystem notificationSystem, StateSynchronizer<io.pravega.client.stream.impl.ReaderGroupState> synchronizer)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description EndOfDataNotifier
getEndOfDataNotifier(java.util.concurrent.ScheduledExecutorService executor)
SegmentNotifier
getSegmentNotifier(java.util.concurrent.ScheduledExecutorService executor)
-
-
-
Constructor Detail
-
NotifierFactory
public NotifierFactory(NotificationSystem notificationSystem, StateSynchronizer<io.pravega.client.stream.impl.ReaderGroupState> synchronizer)
-
-
Method Detail
-
getSegmentNotifier
public SegmentNotifier getSegmentNotifier(java.util.concurrent.ScheduledExecutorService executor)
-
getEndOfDataNotifier
public EndOfDataNotifier getEndOfDataNotifier(java.util.concurrent.ScheduledExecutorService executor)
-
-