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>

public class KeyStreamSupplier<K,V>
extends Object
implements AbstractLocalCacheStream.StreamSupplier<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, ConsistentHash hash, Supplier<Stream<K>> supplier)

Method Summary

Modifier and Type	Method and Description
Stream<K>	buildStream(Set<Integer> segmentsToFilter, Set<?> keysToFilter)
CloseableIterator<K>	removableIterator(CloseableIterator<K> realIterator)

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,
                         ConsistentHash hash,
                         Supplier<Stream<K>> supplier)

Method Detail

buildStream

public Stream<K> buildStream(Set<Integer> segmentsToFilter,
                             Set<?> keysToFilter)

Specified by:

buildStream in interface AbstractLocalCacheStream.StreamSupplier<K>

removableIterator

public CloseableIterator<K> removableIterator(CloseableIterator<K> realIterator)

Specified by:

removableIterator in interface AbstractLocalCacheStream.StreamSupplier<K>