Class EndOfDataNotifier

    • Constructor Detail

      • EndOfDataNotifier

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