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 and Description
KeyStreamSupplier(Cache<K,V> cache, ToIntFunction<Object> toIntFunction, Supplier<Stream<K>> supplier)

Method Summary

Modifier and Type	Method and Description
Stream<K>	buildStream(IntSet segmentsToFilter, Set<?> keysToFilter, boolean parallel)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KeyStreamSupplier

public KeyStreamSupplier(Cache<K,V> cache,
                         ToIntFunction<Object> toIntFunction,
                         Supplier<Stream<K>> supplier)

Method Detail

buildStream

public Stream<K> buildStream(IntSet segmentsToFilter,
                             Set<?> keysToFilter,
                             boolean parallel)

Specified by:

buildStream in interface AbstractLocalCacheStream.StreamSupplier<K,Stream<K>>