Package org.infinispan.reactive.publisher.impl

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

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)

Methods inherited from class java.lang.Object

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

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)