Package org.infinispan

Interface BaseCacheStream.SegmentCompletionListener

  • All Superinterfaces:
    java.util.function.Consumer<java.util.function.Supplier<java.util.PrimitiveIterator.OfInt>>
    All Known Subinterfaces:
    QueueingSegmentListener<K,​V,​E>
    Enclosing interface:
    BaseCacheStream<T,​S extends java.util.stream.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 java.util.function.Consumer<java.util.function.Supplier<java.util.PrimitiveIterator.OfInt>>
    Functional interface that is used as a callback when segments are completed. Please see BaseCacheStream.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​(java.util.function.Supplier<java.util.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
      void segmentCompleted​(java.util.Set<java.lang.Integer> segments)
      Deprecated.
      This method requires boxing for each segment.

      • Methods inherited from interface java.util.function.Consumer

        andThen

    • Method Detail

      • segmentCompleted

        @Deprecated
void segmentCompleted​(java.util.Set<java.lang.Integer> segments)
        Deprecated.
        This method requires boxing for each segment. Please use accept(Supplier) instead
        Method 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​(java.util.function.Supplier<java.util.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
        Specified by:
        accept in interface java.util.function.Consumer<java.util.function.Supplier<java.util.PrimitiveIterator.OfInt>>
        Parameters:
        segments - The segments that were completed