Package org.infinispan.reactive.publisher.impl

Interface SegmentAwarePublisherSupplier.NotificationWithLost<R>

Type Parameters:

R - the value type if present

All Superinterfaces:

SegmentPublisherSupplier.Notification<R>

Enclosing interface:

SegmentAwarePublisherSupplier<R>

public static interface SegmentAwarePublisherSupplier.NotificationWithLost<R>
extends SegmentPublisherSupplier.Notification<R>

Notification that can also contains lost segments. Note that the lost segments are mutually exclusive with value and completed segments.

Method Summary

Modifier and Type	Method	Description
default boolean	isLostSegment()	Whether this notification is for a lost segment
default int	lostSegment()	The segment that was complete for this notification

Methods inherited from interface org.infinispan.reactive.publisher.impl.SegmentPublisherSupplier.Notification

completedSegment, isSegmentComplete, isValue, value, valueSegment

Method Details

isLostSegment

default boolean isLostSegment()

Whether this notification is for a lost segment

Returns:

true if a segment was lost

lostSegment

default int lostSegment()

The segment that was complete for this notification

Returns:

the segment

Throws:

IllegalStateException - if this notification contains a value or has a completed segment