org.infinispan

Interface CacheStream.SegmentCompletionListener

Enclosing interface:

CacheStream<R>

@FunctionalInterface
public static interface CacheStream.SegmentCompletionListener

Functional interface that is used as a callback when segments are completed. Please see CacheStream.segmentCompletionListener(SegmentCompletionListener) for more details.

Since:

8.0

Method Summary

Modifier and Type	Method and Description
void	segmentCompleted(Set<Integer> segments) Method invoked when the segment has been found to be consumed properly by the terminal operation.

Method Detail

segmentCompleted

void segmentCompleted(Set<Integer> segments)

Method invoked when the segment has been found to be consumed properly by the terminal operation.

Parameters:

segments - The segments that were completed