@FunctionalInterface public static interface BaseCacheStream.SegmentCompletionListener extends Consumer<Supplier<PrimitiveIterator.OfInt>>
BaseCacheStream.segmentCompletionListener(SegmentCompletionListener)for more details.
|Modifier and Type||Method and Description|
Invoked each time a given number of segments have completed and the terminal operation has consumed all entries in the given segment
This method requires boxing for each segment. Please use
@Deprecated void segmentCompleted(Set<Integer> segments)
segments- The segments that were completed
default void accept(Supplier<PrimitiveIterator.OfInt> segments)
Copyright © 2020 JBoss, a division of Red Hat. All rights reserved.