Uses of Interface
org.infinispan.reactive.publisher.impl.SegmentAwarePublisherSupplier.NotificationWithLost
-
Uses of SegmentAwarePublisherSupplier.NotificationWithLost in org.infinispan.reactive.publisher.impl
Modifier and TypeMethodDescriptionNotifications.NotificationBuilder.segmentComplete
(int segment) static <R> SegmentAwarePublisherSupplier.NotificationWithLost<R>
Notifications.segmentComplete
(int segment) Notifications.NotificationBuilder.segmentLost
(int segment) static <R> SegmentAwarePublisherSupplier.NotificationWithLost<R>
Notifications.segmentLost
(int segment) static <R> SegmentAwarePublisherSupplier.NotificationWithLost<R>
Notifications.value
(R value, int segment) Modifier and TypeMethodDescriptiondefault org.reactivestreams.Publisher<SegmentAwarePublisherSupplier.NotificationWithLost<R>>
SegmentAwarePublisherSupplier.publisherWithLostSegments()
Same asSegmentPublisherSupplier.publisherWithSegments()
, except that we also can notify a listener when a segment has been lost before publishing all its entries.org.reactivestreams.Publisher<SegmentAwarePublisherSupplier.NotificationWithLost<R>>
SegmentAwarePublisherSupplier.publisherWithLostSegments
(boolean reuseNotifications) Same asSegmentPublisherSupplier.publisherWithSegments()
, except that we also can notify a listener when a segment has been lost before publishing all its entries