Package org.infinispan.stream.impl.local
Class KeyStreamSupplier<K,V>
- java.lang.Object
-
- org.infinispan.stream.impl.local.KeyStreamSupplier<K,V>
-
- All Implemented Interfaces:
AbstractLocalCacheStream.StreamSupplier<K,Stream<K>>
public class KeyStreamSupplier<K,V> extends Object implements AbstractLocalCacheStream.StreamSupplier<K,Stream<K>>
Stream supplier that is to be used when the underlying stream is composed by key instances. This supplier will do the proper filtering by assuming each element is the key itself.
-
-
Constructor Summary
Constructors Constructor Description KeyStreamSupplier(Cache<K,V> cache, ToIntFunction<Object> toIntFunction, Supplier<Stream<K>> supplier)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Stream<K>
buildStream(org.infinispan.commons.util.IntSet segmentsToFilter, Set<?> keysToFilter, boolean parallel)
-
-
-
Method Detail
-
buildStream
public Stream<K> buildStream(org.infinispan.commons.util.IntSet segmentsToFilter, Set<?> keysToFilter, boolean parallel)
- Specified by:
buildStream
in interfaceAbstractLocalCacheStream.StreamSupplier<K,V>
-
-