org.infinispan.stream.impl.local

Class EntryStreamSupplier<K,V>

java.lang.Object

org.infinispan.stream.impl.local.EntryStreamSupplier<K,V>

All Implemented Interfaces:

AbstractLocalCacheStream.StreamSupplier<CacheEntry<K,V>,Stream<CacheEntry<K,V>>>

public class EntryStreamSupplier<K,V>
extends Object
implements AbstractLocalCacheStream.StreamSupplier<CacheEntry<K,V>,Stream<CacheEntry<K,V>>>

Stream supplier that is to be used when the underlying stream is composed by CacheEntry instances. This supplier will do the proper filtering by key based on the CacheEntry key.

Constructor Summary

Constructors

Constructor and Description
EntryStreamSupplier(Cache<K,V> cache, ToIntFunction<Object> toIntFunction, Supplier<Stream<CacheEntry<K,V>>> supplier)

Method Summary

Modifier and Type	Method and Description
Stream<CacheEntry<K,V>>	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

EntryStreamSupplier

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

Method Detail

buildStream

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

Specified by:

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