Class Notifications
- java.lang.Object
-
- org.infinispan.reactive.publisher.impl.Notifications
-
public class Notifications extends Object
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static interface
Notifications.NotificationBuilder<R>
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static <R> Notifications.NotificationBuilder<R>
newBuilder()
static <R> Notifications.NotificationBuilder<R>
reuseBuilder()
static <R> SegmentAwarePublisherSupplier.NotificationWithLost<R>
segmentComplete(int segment)
static <R> SegmentAwarePublisherSupplier.NotificationWithLost<R>
segmentLost(int segment)
static <R> SegmentAwarePublisherSupplier.NotificationWithLost<R>
value(R value, int segment)
-
-
-
Method Detail
-
reuseBuilder
public static <R> Notifications.NotificationBuilder<R> reuseBuilder()
-
newBuilder
public static <R> Notifications.NotificationBuilder<R> newBuilder()
-
value
public static <R> SegmentAwarePublisherSupplier.NotificationWithLost<R> value(R value, int segment)
-
segmentComplete
public static <R> SegmentAwarePublisherSupplier.NotificationWithLost<R> segmentComplete(int segment)
-
segmentLost
public static <R> SegmentAwarePublisherSupplier.NotificationWithLost<R> segmentLost(int segment)
-
-