Package org.infinispan
Interface BaseCacheStream.SegmentCompletionListener
-
- All Superinterfaces:
Consumer<Supplier<PrimitiveIterator.OfInt>>
- Enclosing interface:
- BaseCacheStream<T,S extends BaseStream<T,S>>
- Functional Interface:
- This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
@FunctionalInterface public static interface BaseCacheStream.SegmentCompletionListener extends Consumer<Supplier<PrimitiveIterator.OfInt>>
Functional interface that is used as a callback when segments are completed. Please seeBaseCacheStream.segmentCompletionListener(SegmentCompletionListener)
for more details.- Since:
- 9.0
- Author:
- wburns
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Deprecated Methods Modifier and Type Method Description default void
accept(Supplier<PrimitiveIterator.OfInt> segments)
Invoked each time a given number of segments have completed and the terminal operation has consumed all entries in the given segmentvoid
segmentCompleted(Set<Integer> segments)
Deprecated.This method requires boxing for each segment.
-
-
-
Method Detail
-
segmentCompleted
@Deprecated void segmentCompleted(Set<Integer> segments)
Deprecated.This method requires boxing for each segment. Please useaccept(Supplier)
insteadMethod invoked when the segment has been found to be consumed properly by the terminal operation.- Parameters:
segments
- The segments that were completed
-
accept
default void accept(Supplier<PrimitiveIterator.OfInt> segments)
Invoked each time a given number of segments have completed and the terminal operation has consumed all entries in the given segment- Parameters:
segments
- The segments that were completed
-
-